The problem of kafka consumer group

2018-12-26 Thread MCG
Dear Kafka Team : I encountered some problems in using Kafka2.0.0, In the same consumer group of Kafka cluster, Two consumers consume the same partition, Perhaps the picture in the attachment is more illustrative. Everything works well with Range Assignor, and this problem may ari

?????? KTable.suppress(Suppressed.untilWindowCloses) does not suppresssome non-final results when the kafka streams process is restarted

2018-12-26 Thread MCG
I'm not talking about orderliness, but that the same consumer group, the same partition, is consumed by multiple consumers. I use kafka-consumer-groups.sh and org.apache.kafka.clients.admin.AdminClient to validate the results. Because the same consumer group subscribes to a topic, the same parti