Hi Tarandeep,
The error you are seeing only occurs when on startup of the consumer, it
couldn’t retrieve any partition information from Kafka.
Therefore, according to your description, there should be another error that
caused the previous execution of the job to fail. Could you check that? Mayb
Hi,
Our flink streaming job that is reading from old version of Kafka keeps
failing (every 9 minutes or so) with this error:
java.lang.RuntimeException: Unable to retrieve any partitions for the
requested topics [extracted-dimensions]. Please check previous log entries
at
org.apache.flink
