我正在使用跨多台机器的通用消费者组管理卡夫卡队列。现在我还需要显示队列的当前内容。如何只读取组内尚未读取的消息,同时使这些消息再次被组中实际处理这些消息的其他消费者读取。任何帮助,将不胜感激。
apache-kafka kafka-consumer-api pykafka
apache-kafka ×1
kafka-consumer-api ×1
pykafka ×1