kafka git commit: MINOR: Refer consistently to server.properties in security docs

Repository: kafka Updated Branches: refs/heads/trunk 0cf770800 -> 83bdcdbae MINOR: Refer consistently to server.properties in security docs Author: Manikumar Reddy Reviewers: Ismael Juma Closes #3788 from omkreddy/RULE-DOC Project:

[2/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

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

[1/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

Repository: kafka Updated Branches: refs/heads/trunk a64fe2ed8 -> 0cf770800 http://git-wip-us.apache.org/repos/asf/kafka/blob/0cf77080/clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java -- diff

[6/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

http://git-wip-us.apache.org/repos/asf/kafka/blob/0cf77080/clients/src/main/java/org/apache/kafka/common/protocol/types/BoundField.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/types/BoundField.java

[7/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

http://git-wip-us.apache.org/repos/asf/kafka/blob/0cf77080/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java -- diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java

[8/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

MINOR: Move request/response schemas to the corresponding object representation This refactor achieves the following: 1. Breaks up the increasingly unmanageable `Protocol` class and moves schemas closer to their actual usage. 2. Removes the need for redundant field identifiers maintained

[3/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

http://git-wip-us.apache.org/repos/asf/kafka/blob/0cf77080/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java -- diff --git

[5/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

http://git-wip-us.apache.org/repos/asf/kafka/blob/0cf77080/clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java -- diff --git

[4/8] kafka git commit: MINOR: Move request/response schemas to the corresponding object representation

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

kafka git commit: KAFKA-5918: Fix minor typos and errors in the Kafka Streams turotial

Repository: kafka Updated Branches: refs/heads/trunk d0645aaee -> a64fe2ed8 KAFKA-5918: Fix minor typos and errors in the Kafka Streams turotial I found several minor issues with the Kafka Streams tutorial: * Some typos * "As shown above, it illustrate that the constructed ..." instead of

kafka git commit: KAFKA-5893; Preserve original System.out in PrintedTest

Repository: kafka Updated Branches: refs/heads/trunk f46d414c1 -> d0645aaee KAFKA-5893; Preserve original System.out in PrintedTest Author: Matthias J. Sax Reviewers: Guozhang Wang , Bill Bejeck Closes #3893 from

kafka git commit: KAFKA-5833: Reset thread interrupt state in case of InterruptedException

Repository: kafka Updated Branches: refs/heads/trunk 4ac7c48e9 -> f46d414c1 KAFKA-5833: Reset thread interrupt state in case of InterruptedException Author: Matthias J. Sax Reviewers: Ted Yu , Guozhang Wang Closes #3841 from

kafka git commit: MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations

Repository: kafka Updated Branches: refs/heads/0.11.0 1c9581e2e -> 1df108421 MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations Throws IllegalArgumentException is the offset is negative Author: Mickael Maison Reviewers: Ismael Juma

kafka git commit: MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations

Repository: kafka Updated Branches: refs/heads/trunk ae3eeb3e1 -> 4ac7c48e9 MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations Throws IllegalArgumentException is the offset is negative Author: Mickael Maison Reviewers: Ismael Juma

kafka git commit: MINOR: Make the state change log more consistent

Repository: kafka Updated Branches: refs/heads/trunk f2b74aa1c -> ae3eeb3e1 MINOR: Make the state change log more consistent Use logIdent to achieve this. Also fixed an issue where we were logging about replicas going offline with an empty set of replicas (i.e. no replicas had gone offline

[2/2] kafka git commit: KAFKA-5873; add materialized overloads to StreamsBuilder

KAFKA-5873; add materialized overloads to StreamsBuilder Add overloads for `table` and `globalTable` that use `Materialized` Author: Damian Guy Reviewers: Bill Bejeck , Matthias J. Sax , Guozhang Wang Closes

[1/2] kafka git commit: KAFKA-5873; add materialized overloads to StreamsBuilder

Repository: kafka Updated Branches: refs/heads/trunk 52d7b6763 -> f2b74aa1c http://git-wip-us.apache.org/repos/asf/kafka/blob/f2b74aa1/streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java

kafka git commit: MINOR: Fix replica_verification_tool.py to handle slight change in output format

Repository: kafka Updated Branches: refs/heads/trunk bd83ae6ba -> 52d7b6763 MINOR: Fix replica_verification_tool.py to handle slight change in output format The string representation of TopicPartition was changed to be {topic}-{partitition} consistently in the following commit:

kafka git commit: MINOR: Fix typo in mapper parameter of flatMapValues

Repository: kafka Updated Branches: refs/heads/trunk b363901cb -> bd83ae6ba MINOR: Fix typo in mapper parameter of flatMapValues The parameter is already called `mapper` in the KStreamImpl class. I think it was probably named `processor` here because it was copy/pasted from some other

kafka git commit: KAFKA-5893: more logging for investigating ResetIntegrationTest failures

Repository: kafka Updated Branches: refs/heads/trunk ed0e69214 -> b363901cb KAFKA-5893: more logging for investigating ResetIntegrationTest failures - improve stderr output for better debugging Author: Matthias J. Sax Reviewers: Bill Bejeck ,

kafka git commit: KAFKA-5515; Remove date formatting from Segments

Repository: kafka Updated Branches: refs/heads/trunk be6252d8e -> ed0e69214 KAFKA-5515; Remove date formatting from Segments Remove date formatting from `Segments` and use the `segementId` instead. Add tests to make sure can load old segments. Rename old segment dirs to new formatting at load

kafka git commit: MINOR: Code cleanup, subject: log statements.

Repository: kafka Updated Branches: refs/heads/trunk d83252eba -> be6252d8e MINOR: Code cleanup, subject: log statements. I'm doing this in my spare time, so don't let reviewing this PR take away actual work time. This is just me going over the code with the Intellij analyzer and

kafka git commit: KAFKA-5654; add materialized count, reduce, aggregate to KGroupedStream

Repository: kafka Updated Branches: refs/heads/trunk 346d0ca53 -> d83252eba KAFKA-5654; add materialized count, reduce, aggregate to KGroupedStream Add overloads of `count`, `reduce`, and `aggregate` that are `Materialized` to `KGroupedStream`. Refactor common parts between `KGroupedStream`

kafka git commit: MINOR: Fix needless GC + Result time unit in JMH

Repository: kafka Updated Branches: refs/heads/trunk a3f068e22 -> 346d0ca53 MINOR: Fix needless GC + Result time unit in JMH Fixes two issues with the JMH benchmark example: * Trivial: The output should be in `ops/ms` for readability reasons (it's in the millions of operations per second) *

kafka git commit: MINOR: Update powermock and enable its tests when running with Java 9

Repository: kafka Updated Branches: refs/heads/trunk a339a387e -> a3f068e22 MINOR: Update powermock and enable its tests when running with Java 9 Also: 1. Fix WorkerTest to use the correct `Mock` annotations. `org.easymock.Mock` is not supported by PowerMock 2.x. 2. Rename `powermock` to

kafka git commit: MINOR: Add metric templates for sender/fetcher rate totals

Repository: kafka Updated Branches: refs/heads/trunk f305dd68f -> a339a387e MINOR: Add metric templates for sender/fetcher rate totals Author: Rajini Sivaram Reviewers: James Cheng , Ismael Juma Closes #3882 from

[3/3] kafka git commit: KAFKA-5754; Refactor Streams to use LogContext

KAFKA-5754; Refactor Streams to use LogContext This PR utilizes `org.apache.kafka.common.utils.LogContext` for logging in `KafkaStreams`. hachikuji, ijuma please review this and let me know your thoughts. Author: umesh chaudhary Reviewers: Guozhang Wang