kafka git commit: MINOR: catch a commit failure due to rebalance in StreamThread

Repository: kafka Updated Branches: refs/heads/trunk 982ab09a7 -> 68af16ac1 MINOR: catch a commit failure due to rebalance in StreamThread StreamThread should keep going after a commit was failed due to a group rebalance. Currently the thread just dies. guozhangwang Author: Yasuhiro Matsuda

kafka git commit: HOTFIX: check offset limits in streamtask when recovering KTable store

Repository: kafka Updated Branches: refs/heads/trunk 04585d99c -> 982ab09a7 HOTFIX: check offset limits in streamtask when recovering KTable store guozhangwang Author: Yasuhiro Matsuda Reviewers: Guozhang Wang Closes #947 from ymatsuda/hotfix2

kafka git commit: MINOR - remove unused imports in package kafka.utils

Repository: kafka Updated Branches: refs/heads/trunk d142f8294 -> 04585d99c MINOR - remove unused imports in package kafka.utils Author: zhuchen1018 Reviewers: Grant Henke , Joel Koshy , Dong Lin

kafka git commit: KAFKA-3256; Add print.timestamp option to console consumer.

Repository: kafka Updated Branches: refs/heads/trunk ff7b0f5b4 -> d142f8294 KAFKA-3256; Add print.timestamp option to console consumer. Author: Jiangjie Qin Reviewers: Jun Rao Closes #949 from becketqin/KAFKA-3256 Project:

kafka git commit: HOTFIX: make sure to go through all shutdown steps

Repository: kafka Updated Branches: refs/heads/trunk 46e4d4013 -> ff7b0f5b4 HOTFIX: make sure to go through all shutdown steps Author: Yasuhiro Matsuda Reviewers: Guozhang Wang Closes #928 from ymatsuda/shutdown Project:

kafka git commit: MINOR: Update streams RocksDb to 4.1.0

Repository: kafka Updated Branches: refs/heads/trunk e3ab96b2f -> 46e4d4013 MINOR: Update streams RocksDb to 4.1.0 This is the latest version in Maven even though HISTORY.md includes releases all the way to 4.5.0. Author: Ismael Juma Reviewers: Grant Henke

kafka git commit: MINOR: Example style improvements

Repository: kafka Updated Branches: refs/heads/trunk d2527af99 -> e3ab96b2f MINOR: Example style improvements These are minor, but no reason to make our example code look worse than it has to. Author: Ismael Juma Reviewers: Grant Henke Closes #940 from

kafka git commit: KAFKA-3255: Added unit tests for NetworkClient.connectionDelay(Node node, long now)

Repository: kafka Updated Branches: refs/heads/trunk 49fd0ceb0 -> d2527af99 KAFKA-3255: Added unit tests for NetworkClient.connectionDelay(Node node, long now) Author: Frank Scholten Reviewers: Eno Thereska , Ewen Cheslack-Postava