kafka git commit: KAFKA-5473; handle ZK session expiration properly when a new session can't be established

2017-12-15 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 529786638 -> e5daa40e3 KAFKA-5473; handle ZK session expiration properly when a new session can't be established (WIP: this commit isn't ready to be reviewed yet. I was checking the travis-ci build with the configuration changes in my acco

kafka git commit: KAFKA-5526; Additional `--describe` views for ConsumerGroupCommand (KIP-175)

2017-12-15 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 69777260e -> 529786638 KAFKA-5526; Additional `--describe` views for ConsumerGroupCommand (KIP-175) The `--describe` option of ConsumerGroupCommand is expanded, as proposed in [KIP-175](https://cwiki.apache.org/confluence/display/KAFKA/KIP-

kafka git commit: KAFKA-6086: Provide for custom error handling when Kafka Streams fails to produce

2017-12-15 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 68712dcde -> 69777260e KAFKA-6086: Provide for custom error handling when Kafka Streams fails to produce This PR creates and implements the `ProductionExceptionHandler` as described in [KIP-210](https://cwiki.apache.org/confluence/display/