GitHub user arunmahadevan opened a pull request:
https://github.com/apache/kafka/pull/2820
KAFKA-5039: Logging in BlockingChannel and SyncProducer connect
When an exception is thrown in BlockingChannel::connect, the connection is
disconnected but the actual exception is not logged
GitHub user arunmahadevan opened a pull request:
https://github.com/apache/kafka/pull/1376
KAFKA-3706: Make new consumer as default in kafka console consumer
1. Made new consumer the default in console consumer
2. Added --old-consumer option to choose old consumer
You can merge
GitHub user arunmahadevan opened a pull request:
https://github.com/apache/kafka/pull/1301
KAFKA-3645: Fix NPE in ConsumerGroupCommand and ConsumerOffsetChecker
The host and port entries under /brokers/ids/ gets filled only for
PLAINTEXT security protocol. For other protocols the
