To learn how to create the cluster, see Start with Apache Kafka on HDInsight. The test case is simple: Console Producer and Consumer with (de)serializers using Kafka How to Work with Apache Kafka in Your Spring Boot Application spring.kafka.consumer.properties. Implementing a kafka consumer and kafka producer with Spring Boot This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. If client authentication is required, . A client id is advisable, as it can be used to identify the client as a source for requests in logs and metrics. spring.kafka.consumer.ssl.key-store-location Spring Boot Implementation For Apache Kafka With Kafka Tool Spring Boot Kafka Multiple Consumers Example - HowToDoInJava 1. spring-kafka application.properties · GitHub In this spring Kafka multiple consumer java configuration example, we learned to creates multiple topics using TopicBuilder API. Custom Serializers in Apache Kafka - Baeldung The maven snippet is provided below: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.9.0.0-cp1</version> </dependency> The consumer is constructed using a Properties file just like the other Kafka clients. A client id is advisable, as it can be used to identify the client as a source for requests in logs and metrics. The constructor accepts the following arguments: The topic name / list of topic names; A DeserializationSchema / KafkaDeserializationSchema for deserializing the data from Kafka; Properties for the Kafka consumer. From inside the second terminal on the broker container, run the following command to start a console producer: kafka-avro-console-producer \ --topic . Kafka Producer and Consumer Examples - DZone Big Data Kafka 0.7 Quickstart - Get up and running quickly. Kafka Streams vs. Kafka Consumer - Baeldung If Kafka is running in a cluster then you can provide comma (,) seperated . Client configuration is done by setting the relevant security-related properties for the client. As seen earlier for producer application configuration, we can configure consumer applications with the application.properties file or by using java configuration class.