Using the Apache Kafka Java client (0.9), I'm trying to send a long series of records to the broker using the Kafka Producer class. The asynchronous send method returns immediately for a while, t...

I've read other threads and I've gotten around the problem by using a new group ID, however I'd like to understand what could cause this. I have a topic with 16 partitions, I've set session.timeou...

In trying to use kafkacat with message hub, I've used the following: kafkacat -X client.id=xxxxx \ -X sasl.jaas.config='org.apache.kafka.common.security.plain.PlainLoginModule required username="x...

This issue is now solved on Message Hub I am having some trouble creating a KTable in Kafka. I am new to Kafka, which is probably the root of my problem, but I thought I could ask here anyway. I h...

I have a thread which once in a while is going to list the topics on the Message Hub. But once in a while, I am getting a :Failed to send SSL Close message. Any ideas? KafkaConsumer<String, St...