@Team, I am trying to connect and consume from remote kafka, i am able to get number of partitions but when tried to consume from it not getting any data either start consuming from beginning or from latest. We have multiple topic in this kafka cluster, and there are consumer running for other kafka topic, and this is the first time we are trying to consume from this topic
I do see following in logs INFO 2019-01-08 04:51:20,266 [Thread-30]???[AbstractCoordinator.java:657] : [Consumer clientId=consumer-30, groupId=dev22-icc-repo-aggregator] Group coordinator dev22-kafka2:9092 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery I did google and do see one way to resolve this is to do clean up on topic, not sure if thats the right and only approach. Will you please provide some detail on issue and how to resolve it. Regards Vikas