all messages correctly processed.
Regards,
From: Martijn Visser
Sent: Friday, September 2, 2022 4:54 AM
To: Vasquez, Alfredo
Cc: user@flink.apache.org
Subject: Re: Kafka source stops consuming messages from topic after some minutes
EXTERNAL MESSAGE
My initial thought is that there's some
My initial thought is that there's something in your business logic. You're
reading from one Kafka topic, then you're mentioning that it's "connected"
to another Kafka topic. What type of business logic are you executing? Are
you joining data, looking things up etc? My suspicion would be that in th
Hello,
Im using flink-connector-kafka version 1.15.2 to consume messages from a kafka
topic which has 3 partitions that later its connected to to another kafka
source and then processed in a BroadcastProcessFunction.
The Kafka source is created as follows:
Properties properties = new Propertie
