Hi Kevin,
You can use partition.assignment.strategy=roundrobin.
This will balance all the partition of all the topics across consumer
thread.
I think the rationale behind using default consumer id is that you will
have better information to identify a consumer. But if you want to have
some specif
https://github.com/apache/kafka/blob/0.8.2/core/src/main/scala/kafka/consumer/ConsumerConfig.scala#L101
suggests that 'consumer.id' should only be set explicitly for testing
purposes. Is there a reason that it would be a bad idea to set it
ourselves for production use?
The reason I am asking is t
