Hi Chao, I suppose, you would like to know: within a consumer group which message is coming from which partition, since partitions corresponds to broker and broker = ip, right?
Well, if you really want to know this, then you have to get the context. E.g within a processor there is a method called context().... However, keep in mind broker and IP addresses could change. I would not recommend to build a business logic on top of ip addresses. Within a producer, you can manage the destination partition / broker. Regards Valentin -- > Am 10.12.2019 um 04:48 schrieb 朱超 <chao....@baozun.com>: > > hi: > I am a gteen hand of kafka，after installation of new kafka cluster，it > raises a question that how do I know which IP address a message come > from? Is there any special set about this? > Eagerly awaiting your reply. > > ________________________________ > chao....@baozun.com
