Hi,
I am using kafka in couple of programs including flink and I am quite
confused that how group.id parameter work in flink with kafka comsumer.I
have 2 consumers (one in side flink, one outside) running on the same
topic and same group.id. From my inpection, they work isolately:If
I send one message into the kafka topic, both consumer would receive
it. But acording to the kafka document, only one (same topic same group)
should be able to get the message.
And
i tried to start 2 consumers both inside the flink main function, it
seems that only one consumer would be receiving all messages from kafka.
So, it's quite confused how does flink deal with this kind of situation?
Thanks a lot
