public void KafkaTriggerAndKafkaOutput()

in endtoendtests/src/main/java/com/microsoft/azure/functions/endtoend/KafkaTriggerTests.java [36:53]

18 lines of code
1 McCabe index (conditional complexity)


    public void KafkaTriggerAndKafkaOutput(
            @KafkaTrigger(
                    name = "kafkaTriggerAndKafkaOutput",
                    topic = "ci",
                    brokerList="%BrokerList%",
                    consumerGroup="$Default",
                    username = "%ConfluentCloudUsername%",
                    password = "%ConfluentCloudPassword%",
                    authenticationMode = BrokerAuthenticationMode.PLAIN,
                    protocol = BrokerProtocol.SASLSSL,
                    sslCaLocation = "confluent_cloud_cacert.pem",
                    dataType = "string"
            ) String message,
            @QueueOutput(name = "output", queueName = "test-kafka-output-cardinality-one-java", connection = "AzureWebJobsStorage") OutputBinding<String> output,
            final ExecutionContext context) {
        context.getLogger().info("Java Kafka Output function processed a message: " + message);
        output.setValue(message);
    }