kafka git commit: KAFKA-5314; exception handling and cleanup for state stores

Repository: kafka Updated Branches: refs/heads/trunk 3de2d296e -> f4e0deca4 KAFKA-5314; exception handling and cleanup for state stores Author: Eno Thereska Reviewers: Damian Guy , Matthias J. Sax , Guozhang Wang

kafka git commit: MINOR: improve JavaDocs for TimestampExtractor interface

Repository: kafka Updated Branches: refs/heads/trunk d1a279dcc -> 3de2d296e MINOR: improve JavaDocs for TimestampExtractor interface Author: Matthias J. Sax Reviewers: Guozhang Wang Closes #3264 from mjsax/minor-javadocs-timestamp-extractor

kafka git commit: MINOR: improve JavaDocs for TimestampExtractor interface

Repository: kafka Updated Branches: refs/heads/0.11.0 e692a8455 -> 4f6895e80 MINOR: improve JavaDocs for TimestampExtractor interface Author: Matthias J. Sax Reviewers: Guozhang Wang Closes #3264 from mjsax/minor-javadocs-timestamp-extractor

kafka git commit: MINOR: Cache metrics were missing

Repository: kafka Updated Branches: refs/heads/trunk 12612e829 -> d1a279dcc MINOR: Cache metrics were missing Author: Eno Thereska Reviewers: Guozhang Wang Closes #3262 from enothereska/minor-missing-metric Project:

kafka git commit: MINOR: Cache metrics were missing

Repository: kafka Updated Branches: refs/heads/0.11.0 eb2aa184a -> e692a8455 MINOR: Cache metrics were missing Author: Eno Thereska Reviewers: Guozhang Wang Closes #3262 from enothereska/minor-missing-metric (cherry picked from commit

kafka git commit: KAFKA-5329; Fix order of replica list in metadata cache

Repository: kafka Updated Branches: refs/heads/0.11.0 469778a5a -> eb2aa184a KAFKA-5329; Fix order of replica list in metadata cache Author: Ismael Juma Reviewers: Colin P. Mccabe , Jun Rao Closes #3257 from

kafka git commit: KAFKA-5329; Fix order of replica list in metadata cache

Repository: kafka Updated Branches: refs/heads/trunk 2fc91afba -> 12612e829 KAFKA-5329; Fix order of replica list in metadata cache Author: Ismael Juma Reviewers: Colin P. Mccabe , Jun Rao Closes #3257 from

[2/2] kafka git commit: KAFKA-5292; Fix authorization checks in AdminClient

KAFKA-5292; Fix authorization checks in AdminClient * NetworkClient.java: when trace logging is enabled, show AbstractResponse Struct objects, rather than just a memory address of the AbstractResponse. * AclOperation.java: add documentation of what ACLs imply other ACLs. * Resource.java: add

[1/2] kafka git commit: MINOR: Remove unused method parameter in `SimpleAclAuthorizer`

Repository: kafka Updated Branches: refs/heads/0.11.0 d1acbe9f8 -> 469778a5a MINOR: Remove unused method parameter in `SimpleAclAuthorizer` Author: Vahid Hashemian Reviewers: Ismael Juma Closes #3147 from

kafka git commit: KAFKA-5292; Fix authorization checks in AdminClient

Repository: kafka Updated Branches: refs/heads/trunk 79db393ff -> 2fc91afba KAFKA-5292; Fix authorization checks in AdminClient * NetworkClient.java: when trace logging is enabled, show AbstractResponse Struct objects, rather than just a memory address of the AbstractResponse. *

kafka git commit: KAFKA-5385; ProducerBatch expiry should go through Sender.failBatch

Repository: kafka Updated Branches: refs/heads/0.11.0 1266d4f9e -> d1acbe9f8 KAFKA-5385; ProducerBatch expiry should go through Sender.failBatch Before this patch, we would call `producerBatch.done` directly from the accumulator when expiring batches. This meant that we would not transition

kafka git commit: MINOR: A few logging improvements in group coordinator

Repository: kafka Updated Branches: refs/heads/0.11.0 d9c022beb -> 1266d4f9e MINOR: A few logging improvements in group coordinator Author: Jason Gustafson Reviewers: Ismael Juma Closes #3259 from hachikuji/group-coordinator-logging-improvements

kafka git commit: MINOR: A few logging improvements in group coordinator

Repository: kafka Updated Branches: refs/heads/trunk 6aeca1012 -> effda15f1 MINOR: A few logging improvements in group coordinator Author: Jason Gustafson Reviewers: Ismael Juma Closes #3259 from hachikuji/group-coordinator-logging-improvements

kafka git commit: KAFKA-5389; Replace zkClient.exists method with zkUtils.pathExists

Repository: kafka Updated Branches: refs/heads/trunk 38ae74644 -> 6aeca1012 KAFKA-5389; Replace zkClient.exists method with zkUtils.pathExists ijuma can you please review Author: Balint Molnar Reviewers: Ismael Juma Closes #3243 from

kafka git commit: KAFKA-5394; KafkaAdminClient#timeoutCallsInFlight does not work as ex… KAFKA-5394; Fix disconnections due to timeouts in AdminClient

Repository: kafka Updated Branches: refs/heads/0.11.0 71474a6f8 -> d9c022beb KAFKA-5394; KafkaAdminClient#timeoutCallsInFlight does not work as ex… KAFKA-5394; Fix disconnections due to timeouts in AdminClient * Create KafkaClient#disconnect to tear down a connection and deliver disconnects

kafka git commit: KAFKA-5394; KafkaAdminClient#timeoutCallsInFlight does not work as ex… KAFKA-5394; Fix disconnections due to timeouts in AdminClient

Repository: kafka Updated Branches: refs/heads/trunk 5c3d7ca71 -> 38ae74644 KAFKA-5394; KafkaAdminClient#timeoutCallsInFlight does not work as ex… KAFKA-5394; Fix disconnections due to timeouts in AdminClient * Create KafkaClient#disconnect to tear down a connection and deliver disconnects

kafka git commit: MINOR: log4j template should accept log_level

Repository: kafka Updated Branches: refs/heads/0.11.0 172041d57 -> 71474a6f8 MINOR: log4j template should accept log_level The log_level parameter is used in system tests in kafka.py. However the log4j template accepted that parameter in only one place. This led to a large number of DEBUG

kafka git commit: KAFKA-5378; Return LSO in FetchResponse plus some metrics

Repository: kafka Updated Branches: refs/heads/trunk 57b0d0fe5 -> dcbdce31b KAFKA-5378; Return LSO in FetchResponse plus some metrics Author: Jason Gustafson Reviewers: Jun Rao , Ismael Juma Closes #3248 from hachikuji/KAFKA-5378

kafka git commit: KAFKA-5378; Return LSO in FetchResponse plus some metrics

Repository: kafka Updated Branches: refs/heads/0.11.0 60d2f1294 -> 172041d57 KAFKA-5378; Return LSO in FetchResponse plus some metrics Author: Jason Gustafson Reviewers: Jun Rao , Ismael Juma Closes #3248 from hachikuji/KAFKA-5378

[1/2] kafka git commit: MINOR: syntax brush for java / bash / json / text

Repository: kafka Updated Branches: refs/heads/trunk f8d6dba34 -> 57b0d0fe5 http://git-wip-us.apache.org/repos/asf/kafka/blob/57b0d0fe/docs/streams.html -- diff --git a/docs/streams.html b/docs/streams.html index

[2/2] kafka git commit: MINOR: syntax brush for java / bash / json / text

MINOR: syntax brush for java / bash / json / text Author: Guozhang Wang Reviewers: Derrick Or , Ismael Juma Closes #3214 from guozhangwang/KMinor-doc-java-brush Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/2] kafka git commit: MINOR: syntax brush for java / bash / json / text

MINOR: syntax brush for java / bash / json / text Author: Guozhang Wang Reviewers: Derrick Or , Ismael Juma Closes #3214 from guozhangwang/KMinor-doc-java-brush (cherry picked from commit 57b0d0fe572399048e523d54beafa3520a708cf5)

kafka git commit: MINOR: set group initial rebalance delay to 0 in server.properties

Repository: kafka Updated Branches: refs/heads/0.11.0 2f5b652a3 -> 5363cd4c6 MINOR: set group initial rebalance delay to 0 in server.properties override the setting of `group.initial.rebalance.delay` in server.properties Author: Damian Guy Reviewers: Ismael Juma

kafka git commit: MINOR: set group initial rebalance delay to 0 in server.properties

Repository: kafka Updated Branches: refs/heads/trunk bb914a044 -> f8d6dba34 MINOR: set group initial rebalance delay to 0 in server.properties override the setting of `group.initial.rebalance.delay` in server.properties Author: Damian Guy Reviewers: Ismael Juma

kafka git commit: KAFKA-5395; Remove synchronization from AbstractCoordinator.close, remove duplication

Repository: kafka Updated Branches: refs/heads/0.10.2 bac27673f -> b18ca2543 KAFKA-5395; Remove synchronization from AbstractCoordinator.close, remove duplication Cherry-picked from trunk. Author: Armin Braun Reviewers: Ismael Juma , Jason Gustafson

kafka git commit: KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers

Repository: kafka Updated Branches: refs/heads/0.11.0 3d0f0caf7 -> 2f5b652a3 KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers 1. Fix ordering of metadata update request for regex subscription to avoid timing issue when heartbeat thread updates metadata 2. Override

kafka git commit: KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers

Repository: kafka Updated Branches: refs/heads/trunk b01c83ea9 -> bb914a044 KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers 1. Fix ordering of metadata update request for regex subscription to avoid timing issue when heartbeat thread updates metadata 2. Override