Top "Kafka-producer-api" questions

Use for questions related to the Apache Kafka producer API.

No serviceName defined in either JAAS or Kafka config (not Kerberos)

I'm trying to configure a kafka client to authenticate against a secure kafkaserver. I've set up the jaas and ssl …

apache-kafka kafka-producer-api apache-kafka-security
org.apache.kafka.common.config.ConfigException: Missing required configuration "bootstrap.servers" which has no default value

I'm getting this error when running my producer class in Eclipse: org.apache.kafka.common.config.ConfigException: Missing required configuration "…

apache-kafka kafka-producer-api
Difference between request.timeout.ms and timeout.ms properties of Kafka producer

Refering the kafka documentation, a Kafka message prducer configuration have request.timeout.ms and timeout.ms properties. Reading the discription …

apache-kafka kafka-producer-api
Kafka: The message when serialized is larger than the maximum request size you have configured with the max.request.size configuration

Getting the following error (Kafka 2.1.0): 2018-12-03 21:22:37.873 ERROR 37645 --- [nio-8080-exec-1] o.s.k.support.LoggingProducerListener : Exception thrown when sending …

apache-kafka kafka-consumer-api kafka-producer-api spring-kafka
Apache Kafka - linger.ms and batch.size settings

In kafka producer settings, what is the expected behavior if you have linger.ms set to 0 and a non zero …

apache-kafka kafka-producer-api
Reproducing UnknownTopicOrPartitionException: This server does not host this topic-partition

We have encountered few exception on production environment: UnknownTopicOrPartitionException: This server does not host this topic-partition As per my analysis, …

apache-kafka kafka-producer-api
Does kafka have any default web UI

I have a couple questions in Kafka. 1) Does Kafka have a default web UI? 2) How can we gracefully shutdown a …

apache-kafka kafka-consumer-api kafka-producer-api
Kafka - difference between Log end offset(LEO) vs High Watermark(HW)

What is the difference between LEO and HW in Replica ( Leader Replica)? Will they contain the same number? I can …

apache-kafka kafka-consumer-api kafka-producer-api
KafkaProducer: Difference between `callback` and returned `Future`?

The KafkaProducer send method both returns a Future and accepts a Callback. Is there any fundamental difference between using one …

java apache-kafka kafka-producer-api
kafka failed authentication due to: SSL handshake failed

I have to add encryption and authentication with SSL in kafka. This is what I have done: Generate certificate for …

apache-kafka kafka-consumer-api kafka-producer-api