kafka git commit: KAFKA-5541: Streams should not re-throw if suspending/closing tasks fails

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk e2e8d4a57 -> a1ea53606 KAFKA-5541: Streams should not re-throw if suspending/closing tasks fails Author: Matthias J. Sax Reviewers: Damian Guy , Bill Bejeck , Guozhang Wang Closes #4037 from mjsax/kafka-5541-dont-rethrow-on-suspend-or-c

kafka git commit: MINOR: KIP-161 upgrade docs change

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/1.0 f899c735d -> 529873146 MINOR: KIP-161 upgrade docs change Author: Guozhang Wang Reviewers: Damian Guy Closes #4036 from guozhangwang/KMinor-kip-161-docs (cherry picked from commit e2e8d4a57a83693b946c3e26f9be2e41a7341ab4) Signed-off-by: G

kafka git commit: MINOR: KIP-161 upgrade docs change

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 51063441d -> e2e8d4a57 MINOR: KIP-161 upgrade docs change Author: Guozhang Wang Reviewers: Damian Guy Closes #4036 from guozhangwang/KMinor-kip-161-docs Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-

kafka git commit: KAFKA-5362; Follow up to Streams EOS system test

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/1.0 d3a603cb9 -> f899c735d KAFKA-5362; Follow up to Streams EOS system test - improve tests to get rid of calls to `sleep` in Python - fixed some flaky test conditions - improve debugging Author: Matthias J. Sax Reviewers: Damian Guy , Bill

kafka git commit: KAFKA-5362; Follow up to Streams EOS system test

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 91517e8fb -> 51063441d KAFKA-5362; Follow up to Streams EOS system test - improve tests to get rid of calls to `sleep` in Python - fixed some flaky test conditions - improve debugging Author: Matthias J. Sax Reviewers: Damian Guy , Bil

kafka git commit: KAFKA-5829; Only delete producer snapshots before the recovery point

2017-10-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/1.0 963733cd0 -> d3a603cb9 KAFKA-5829; Only delete producer snapshots before the recovery point Author: Ismael Juma Reviewers: Jason Gustafson Closes #4023 from ijuma/kafka-5829-avoid-reading-older-segments-on-hard-shutdown (cherry picked fro

kafka git commit: KAFKA-5829; Only delete producer snapshots before the recovery point

2017-10-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 2427a4476 -> 91517e8fb KAFKA-5829; Only delete producer snapshots before the recovery point Author: Ismael Juma Reviewers: Jason Gustafson Closes #4023 from ijuma/kafka-5829-avoid-reading-older-segments-on-hard-shutdown Project: http:/

kafka git commit: MINOR: log4j improvements on assigned tasks and store changelog reader

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/1.0 12c77b4b0 -> 963733cd0 MINOR: log4j improvements on assigned tasks and store changelog reader Author: Guozhang Wang Reviewers: Matthias J. Sax , Xavier Léauté , Damian Guy , Bill Bejeck Closes #4031 from guozhangwang/KMinor-assigned-ta

kafka git commit: MINOR: log4j improvements on assigned tasks and store changelog reader

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 23a014052 -> 2427a4476 MINOR: log4j improvements on assigned tasks and store changelog reader Author: Guozhang Wang Reviewers: Matthias J. Sax , Xavier Léauté , Damian Guy , Bill Bejeck Closes #4031 from guozhangwang/KMinor-assigned-

[1/2] kafka git commit: KAFKA-5651; Follow-up: add with method to Materialized

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/1.0 aa1e4c235 -> 12c77b4b0 http://git-wip-us.apache.org/repos/asf/kafka/blob/12c77b4b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java -

[1/2] kafka git commit: KAFKA-5651; Follow-up: add with method to Materialized

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 105ab47ed -> 23a014052 http://git-wip-us.apache.org/repos/asf/kafka/blob/23a01405/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java ---

[2/2] kafka git commit: KAFKA-5651; Follow-up: add with method to Materialized

2017-10-06 Thread guozhang
KAFKA-5651; Follow-up: add with method to Materialized Add a `with(Serde keySerde, Serde valSerde)` to `Materialized` for cases where people don't care about the state store name. Author: Damian Guy Reviewers: Guozhang Wang , Ismael Juma , Matthias J. Sax Closes #4009 from dguy/materialized

[2/2] kafka git commit: KAFKA-5651; Follow-up: add with method to Materialized

2017-10-06 Thread guozhang
KAFKA-5651; Follow-up: add with method to Materialized Add a `with(Serde keySerde, Serde valSerde)` to `Materialized` for cases where people don't care about the state store name. Author: Damian Guy Reviewers: Guozhang Wang , Ismael Juma , Matthias J. Sax Closes #4009 from dguy/materialized

kafka git commit: KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset

2017-10-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/1.0 ebeee3c8d -> aa1e4c235 KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset It is possible for batches with sequence numbers to be in the `deque` while at the same time the in flight batches in the `TransactionManager` are removed

kafka git commit: KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset

2017-10-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 10cd98cc8 -> 105ab47ed KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset It is possible for batches with sequence numbers to be in the `deque` while at the same time the in flight batches in the `TransactionManager` are remove

kafka git commit: KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics

2017-10-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/1.0 32ee1a879 -> ebeee3c8d KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics Author: Manikumar Reddy Reviewers: Rajini Sivaram , Ismael Juma , Jason Gustafson Closes #3924 from omkreddy/KAFKA-5547-TOPIC-AUT

kafka git commit: KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics

2017-10-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk fb6ca658d -> 10cd98cc8 KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for topics Author: Manikumar Reddy Reviewers: Rajini Sivaram , Ismael Juma , Jason Gustafson Closes #3924 from omkreddy/KAFKA-5547-TOPIC-A

kafka git commit: MINOR: Allow schedule and commit in MockProcessorContext

2017-10-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 974d6fec9 -> fb6ca658d MINOR: Allow schedule and commit in MockProcessorContext This change allows for testing custom Processors and Transformers that call `schedule` and `commit` using KStreamTestDriver, by _not_ throwing `UnsupportedOper

kafka git commit: KAFKA-5953: Register all jdbc drivers available in plugin and class paths

2017-10-06 Thread ewencp
Repository: kafka Updated Branches: refs/heads/1.0 b113b4bd3 -> 32ee1a879 KAFKA-5953: Register all jdbc drivers available in plugin and class paths Author: Konstantine Karantasis Reviewers: Randall Hauch , Ewen Cheslack-Postava Closes #4030 from kkonstantine/KAFKA-5953-Connect-classloade

kafka git commit: KAFKA-5953: Register all jdbc drivers available in plugin and class paths

2017-10-06 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 196bcfca0 -> 974d6fec9 KAFKA-5953: Register all jdbc drivers available in plugin and class paths Author: Konstantine Karantasis Reviewers: Randall Hauch , Ewen Cheslack-Postava Closes #4030 from kkonstantine/KAFKA-5953-Connect-classloa

kafka-site git commit: Adding google tracking file for youtube metrics

2017-10-06 Thread damianguy
Repository: kafka-site Updated Branches: refs/heads/asf-site 3dafcaad2 -> 450fdd86e Adding google tracking file for youtube metrics guozhangwang dguy Please review this. Thanks!! Author: Manjula K Reviewers: Damian Guy Closes #91 from manjuapu/asf-site Project: http://git-wip-us.apache.