Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

i 'm not able to see my consumed data with kafka

i 'm not able to see my consumed data with kafka

New Contributor

Hello

I found a problem while using rsyslog (Omkafka) to send log to kafka.

So i search in the logs and i found this. Any idea,any suggesion Please.

[2018-11-26 17:06:29,702] INFO [GroupCoordinator 1001]: Preparing to restabilize group console-consumer-65890 with old generation 1 (kafka.coordinator.GroupCoordinator) [2018-11-26 17:06:29,702] INFO [GroupCoordinator 1001]: Group console-consumer-65890 with generation 2 is now empty (kafka.coordinator.GroupCoordinator) [2018-11-26 17:06:56,563] INFO [GroupCoordinator 1001]: Preparing to restabilize group console-consumer-95312 with old generation 0 (kafka.coordinator.GroupCoordinator) [2018-11-26 17:06:56,563] INFO [GroupCoordinator 1001]: Stabilized group console-consumer-95312 generation 1 (kafka.coordinator.GroupCoordinator) [2018-11-26 17:06:56,566] INFO [GroupCoordinator 1001]: Assignment received from leader for group console-consumer-95312 for generation 1 (kafka.coordinator.GroupCoordinator) [2018-11-26 17:07:01,405] INFO [GroupCoordinator 1001]: Preparing to restabilize group console-consumer-95312 with old generation 1 (kafka.coordinator.GroupCoordinator) [2018-11-26 17:07:01,406] INFO [GroupCoordinator 1001]: Group console-consumer-95312 with generation 2 is now empty (kafka.coordinator.GroupCoordinator) [2018-11-26 17:10:42,034] INFO [Group Metadata Manager on Broker 1001]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager) [2018-11-26 17:20:42,034] INFO [Group Metadata Manager on Broker 1001]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager) [2018-11-26 17:30:42,034] INFO [Group Metadata Manager on Broker 1001]: Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)