About regression introduced in KIP-962 fixed in KAFKA-19208

Hi everyone, I'm upgrading my old Kafka Stream application currently in 2.6. to 3.8.1 version. But I'm facing a bug where some KStream-GlobalKTable left join doesn't work anymore and instead Drop records, and that's a regression from my 2.6.1 version. What I have is a Kstream With K1,V1 Avro rec

Re: Kafka Consumer Not Receiving Messages – Request for Help

I would suggest that you use the command line tools located in the Kafka distribution to analyze the state of your topic and consumer when running. Just unpack the distribution and you will find them in the bin folder. kafka-topics and kafka-consumer-group have a describe option that will prob

[VOTE] 4.1.0 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 4.1.0. The release brings many new features and improvements: - Mechanism for plugin to register metrics - Allow running multiple versions of connector plugins - Queue are now in preview

Re: Kafka Consumer Not Receiving Messages – Request for Help

Hi Suresh, and others, Thank you for your reply. To provide some additional context: there is only one producer and one consumer running, and nothing else is currently interacting with this Kafka instance. Each time I run my test scenario, I start from a clean slate: 1. Deploy the Kafka instan

Kafka Consumer Not Receiving Messages – Request for Help

Hello everyone, I'm currently working with a single Kafka 3.9.1 instance running in Docker, and I've set up a single topic named "jupiter-events". My Kafka producer is successfully sending messages to the topic, and I've confirmed that these messages are being received by the Kafka instance. H

Re: Kafka Consumer Not Receiving Messages – Request for Help

Hi Suresh, and others, I've attached the Java code snippets for both the producer and the consumer, along with the output from the most recent run. As shown in the producer log, the messages are being sent successfully—they are assigned to a partition and given an offset as expected. However, t

Re: Kafka Consumer Not Receiving Messages – Request for Help

Hi Jakob, The consumer is not consuming the messages because the messages might have already been consumed using the consumer group, jupiter-workers. So, the options below will help you read the messages. 1. Change the group.id from jupiter-workers to something else like jupiter-workers-latest 2.