Hi Shannon,
Some questions:
which Flink version are you using?
Can you provide me with some more logs, in particular the log entries
before this event from the Kafka connector.
Also, it is possible that the Kafka broker was in an erroneous state?
Did the error happen after weeks of data consump
Does anyone have a guess what might cause this exception?
java.lang.RuntimeException: Unable to find a leader for partitions:
[FetchPartition {topic=usersignals, partition=1, offset=2825838}]
at
org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.findLeaderForPartitions(LegacyF
