kafka git commit: HOTFIX: ClassCastException in request logging

Repository: kafka Updated Branches: refs/heads/trunk 1f1e794ad -> a515e9357 HOTFIX: ClassCastException in request logging Author: Jason Gustafson Reviewers: Colin P. Mccabe , Ewen Cheslack-Postava Closes #2566 from hachikuji/hotfix-request-logging Project: http://git-wip-us.apache.org/r

kafka git commit: KAFKA-4317: Regularly checkpoint StateStore changelog offsets

Repository: kafka Updated Branches: refs/heads/trunk fc1cfe475 -> 1f1e794ad KAFKA-4317: Regularly checkpoint StateStore changelog offsets Currently the checkpoint file is deleted at state store initialization and it is only ever written again during a clean shutdown. This can result in signi

[3/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.

[1/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

Repository: kafka Updated Branches: refs/heads/trunk 1f2ee5f0a -> fc1cfe475 http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/core/src/test/scala/unit/kafka/server/BaseRequestTest.scala -- diff --git a/core/src/test/sc

[4/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java b/clie

[5/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

MINOR: Remove Struct from Request/Response classes More details: * Replaced `struct` field in Request/Response with a `toStruct` method. This makes the performance model (including memory usage) easier to understand. Note that requests have `toStruct()` while responses have `toStruct(version)`. *

[2/5] kafka git commit: MINOR: Remove Struct from Request/Response classes

http://git-wip-us.apache.org/repos/asf/kafka/blob/fc1cfe47/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java -- diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/Fetche

kafka git commit: KAFKA-4340; Follow-up fixing system test failures and handling non default log.retention.ms

Repository: kafka Updated Branches: refs/heads/trunk a88737929 -> 1f2ee5f0a KAFKA-4340; Follow-up fixing system test failures and handling non default log.retention.ms Author: Jiangjie Qin Reviewers: Jun Rao , Ismael Juma Closes #2544 from becketqin/KAFKA-4340_follow_up Project: http://

kafka git commit: KAFKA-4775; Fix findbugs warnings in kafka-tools

Repository: kafka Updated Branches: refs/heads/trunk 505af6bfd -> a88737929 KAFKA-4775; Fix findbugs warnings in kafka-tools Author: Colin P. Mccabe Reviewers: Ismael Juma Closes #2559 from cmccabe/KAFKA-4775 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-w