Use for questions related to the Apache Kafka producer API.
I want to ensure whether kafka server is running or not before starting production and consumption jobs. It is in …
java apache-kafka kafka-producer-apiI am starting to learn Kafka for enterprise solution purposes. During my readings, some questions came to my mind: When …
apache-kafka kafka-consumer-api kafka-producer-apiKeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); …
apache-kafka kafka-consumer-api kafka-producer-apiI am trying to load a simple text file instead of standard input in Kafka. After downloading Kafka, I performed …
file apache-kafka kafka-consumer-api kafka-producer-apiWhat is the bestway to create topics in kafka? How many replicas/partitions to be defined when we create topics? …
apache-kafka kafka-consumer-api kafka-producer-apiI am using Kafka producer client and i don't have any log4j configuration in my project. On running, the …
logging log4j apache-kafka kafka-producer-apiI'm pretty sure the bootstrap.servers is correct. Is there anything confliction in Maven or what wrong with Kafka?? Before …
java maven apache-kafka kafka-producer-apiI am looking for some clarification on the subject. In Kafka documentations I found the following: Kafka only provides a …
apache-kafka kafka-consumer-api kafka-producer-apiI am using Kafka with Spring-boot: Kafka Producer class: @Service public class MyKafkaProducer { @Autowired private KafkaTemplate<String, String> …
apache-kafka kafka-consumer-api kafka-producer-api spring-kafkaI want to use kafka on our production environment. I want to know if the latest version of client is …
apache-kafka kafka-producer-api