无论如何,基于correlationID(类似于JMS规范中的那个)在kafka中接收消息.我想创建一组听取同一主题但具有不同相关ID的消费者?
apache-kafka
apache-kafka ×1