kafka git commit: KAFKA-5957; Prevent second deallocate if response for aborted batch returns

Repository: kafka Updated Branches: refs/heads/trunk 021d8a8e9 -> a86873be5 KAFKA-5957; Prevent second deallocate if response for aborted batch returns Author: Jason Gustafson Reviewers: Apurva Mehta , Ismael Juma Closes #3942 from hachikuji/KAFKA-5957 Project: http://git-wip-us.apache.o

kafka-site git commit: update main bullet verbiage on the homepage

Repository: kafka-site Updated Branches: refs/heads/asf-site f5884f1e3 -> 851b2683e update main bullet verbiage on the homepage Author: Derrick Or Reviewers: Ewen Cheslack-Postava Closes #87 from derrickdoo/homepage-updates-092717 Project: http://git-wip-us.apache.org/repos/asf/kafka-sit

[3/3] kafka git commit: KAFKA-5746; Add new metrics to support health checks (KIP-188)

KAFKA-5746; Add new metrics to support health checks (KIP-188) Adds new metrics to support health checks: 1. Error rates for each request type, per-error code 2. Request size and temporary memory size 3. Message conversion rate and time 4. Successful and failed authentication rates 5. ZooKeeper la

[1/3] kafka git commit: KAFKA-5746; Add new metrics to support health checks (KIP-188)

Repository: kafka Updated Branches: refs/heads/trunk dd6347a5d -> 021d8a8e9 http://git-wip-us.apache.org/repos/asf/kafka/blob/021d8a8e/core/src/main/scala/kafka/server/KafkaApis.scala -- diff --git a/core/src/main/scala/kafka/s

[2/3] kafka git commit: KAFKA-5746; Add new metrics to support health checks (KIP-188)

http://git-wip-us.apache.org/repos/asf/kafka/blob/021d8a8e/clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRes

kafka git commit: KAFKA-5888; System test to check ordering of messages with transactions and max.in.flight > 1

Repository: kafka Updated Branches: refs/heads/trunk 89ba0c152 -> dd6347a5d KAFKA-5888; System test to check ordering of messages with transactions and max.in.flight > 1 To check ordering, we augment the existing transactions test to read and write from topics with one partition. Since we ar

kafka git commit: KAFKA-5901: Added Connect metrics specific to source tasks (KIP-196)

Repository: kafka Updated Branches: refs/heads/trunk 9d0a89aea -> 89ba0c152 KAFKA-5901: Added Connect metrics specific to source tasks (KIP-196) Added Connect metrics specific to source tasks, and builds upon #3864 and #3911 that have already been merged into `trunk`. Author: Randall Hauch

kafka git commit: HOTFIX: fix build compilation error

Repository: kafka Updated Branches: refs/heads/trunk 071f9fe1a -> 9d0a89aea HOTFIX: fix build compilation error Author: Damian Guy Reviewers: Ismael Juma Closes #3981 from dguy/fix-build Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos

kafka git commit: MINOR: Use full package name when classes referenced in documentation

Repository: kafka Updated Branches: refs/heads/trunk 983280c45 -> 071f9fe1a MINOR: Use full package name when classes referenced in documentation The `metric.reporters` description in the documentation says to implement the `MetricReporter` class, but the actual class is `MetricsReporter`. [

kafka git commit: KAFKA-5976; Improve trace logging in RequestChannel.sendResponse

Repository: kafka Updated Branches: refs/heads/trunk e846daa89 -> 983280c45 KAFKA-5976; Improve trace logging in RequestChannel.sendResponse It now records the correct size for `Send` and does more appropriate logging if the connection is being closed or if no response is being sent. Author:

kafka git commit: KAFKA-5979; Use single AtomicCounter to generate internal names

Repository: kafka Updated Branches: refs/heads/trunk e5f2471c5 -> e846daa89 KAFKA-5979; Use single AtomicCounter to generate internal names Author: Matthias J. Sax Reviewers: Bill Bejeck , Damian Guy Closes #3979 from mjsax/kafka-5979-kip-120-regression Project: http://git-wip-us.apache.

[2/2] kafka git commit: KAFKA-5949; User Callback Exceptions need to be handled properly

KAFKA-5949; User Callback Exceptions need to be handled properly - catch user exception in user callback (TimestampExtractor, DeserializationHandler, StateRestoreListener) and wrap with StreamsException Additional cleanup: - rename globalRestoreListener to userRestoreListener - remove unneces

[1/2] kafka git commit: KAFKA-5949; User Callback Exceptions need to be handled properly

Repository: kafka Updated Branches: refs/heads/trunk 2703fda52 -> e5f2471c5 http://git-wip-us.apache.org/repos/asf/kafka/blob/e5f2471c/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java --

kafka git commit: KAFKA-5960; Follow-up cleanup [Forced Update!]

Repository: kafka Updated Branches: refs/heads/trunk 675e54f9e -> 2703fda52 (forced update) KAFKA-5960; Follow-up cleanup Author: Jason Gustafson Reviewers: Ismael Juma Closes #3976 from hachikuji/version-fix-followup Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: htt

kafka git commit: KAFKA-5960; MINOR: Follow-up cleanup of

Repository: kafka Updated Branches: refs/heads/trunk e1543a5a8 -> 675e54f9e KAFKA-5960; MINOR: Follow-up cleanup of Author: Jason Gustafson Reviewers: Ismael Juma Closes #3976 from hachikuji/version-fix-followup Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://gi

kafka git commit: KAFKA-5958; Global stores access state restore listener

Repository: kafka Updated Branches: refs/heads/trunk 1444b7b59 -> e1543a5a8 KAFKA-5958; Global stores access state restore listener Author: Bill Bejeck Reviewers: Damian Guy Closes #3973 from bbejeck/KAFKA-5958_global_stores_access_state_restore_listener Project: http://git-wip-us.apache