This problem exists in the current "dev" branch, not it 0.10.0. (Though there may be other problem.)
So the KafkaInput plugin exposes a "group" option that can be used to specify the consumer group this consumer is part of. But since 25fa781238c73f90f61f750fa7f8b58d0421f514 that option has no effect: k.config.Group is no longer passed to sarama.NewConsumer.
This issue is somewhat related to #1910, but it's a different issue.
This problem exists in the current "dev" branch, not it 0.10.0. (Though there may be other problem.)
So the KafkaInput plugin exposes a "group" option that can be used to specify the consumer group this consumer is part of. But since 25fa781238c73f90f61f750fa7f8b58d0421f514 that option has no effect:
k.config.Group
is no longer passed tosarama.NewConsumer
.This issue is somewhat related to #1910, but it's a different issue.