kafka git commit: KAFKA-5330: Use per-task converters in Connect

2017-09-21 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 402aa093d -> 7c988a3c8 KAFKA-5330: Use per-task converters in Connect Instead of sharing the same converter instance within the worker, use a converter per task. More details: - https://github.com/confluentinc/schema-registry/issues/514 -

kafka git commit: KAFKA-5937: Improve ProcessorStateManager exception handling

2017-09-21 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 36afd1095 -> 402aa093d KAFKA-5937: Improve ProcessorStateManager exception handling Author: Matthias J. Sax Reviewers: Ted Yu , Damian Guy , Guozhang Wang

kafka-site git commit: Line logo to Powered-by page + minor edits to styles +google webmaster file

2017-09-21 Thread guozhang
Repository: kafka-site Updated Branches: refs/heads/asf-site a872ac8a1 -> b818b7b0c Line logo to Powered-by page + minor edits to styles +google webmaster file dguy guozhangwang Can you please review this PR? Author: Manjula K Reviewers: Guozhang Wang

kafka git commit: MINOR: Adding LINE corp logo to streams page

2017-09-21 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk ea533f0c5 -> 36afd1095 MINOR: Adding LINE corp logo to streams page Author: Manjula K Author: manjuapu Reviewers: Guozhang Wang Closes #3940 from

kafka git commit: KAFKA-5913; Add hasOffset() and hasTimestamp() methods to RecordMetadata

2017-09-21 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 690575ec4 -> ea533f0c5 KAFKA-5913; Add hasOffset() and hasTimestamp() methods to RecordMetadata These methods help users check for cases in which this metadata was not returned by the broker (e.g. in the case of acks=0 or a duplicate error

kafka git commit: MINOR: Follow-up improvements on top of KAFKA-5793

2017-09-21 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk c8c6ab632 -> 690575ec4 MINOR: Follow-up improvements on top of KAFKA-5793 Simplified the condition in Sender#failBatch() Added log in TransactionManager#updateLastAckedOffset() Author: tedyu Reviewers: Jason

kafka git commit: KAFKA-5735; KIP-190: Handle client-ids consistently

2017-09-21 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk afaaea809 -> c8c6ab632 KAFKA-5735; KIP-190: Handle client-ids consistently Developed with edoardocomar Author: Mickael Maison Reviewers: Edoardo Comar , Rajini Sivaram

kafka git commit: KAFKA-5954; Correct Connect REST API system test

2017-09-21 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk a553764c8 -> afaaea809 KAFKA-5954; Correct Connect REST API system test Author: Randall Hauch Reviewers: tedyu , Ismael Juma Closes #3934 from rhauch/kafka-5954 Project:

kafka git commit: KAFKA-5856; AdminClient.createPartitions() follow-up (KIP-195)

2017-09-21 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 96ba21e0d -> a553764c8 KAFKA-5856; AdminClient.createPartitions() follow-up (KIP-195) - Remove DelayedCreatePartitions to reduce code duplication - Avoid unnecessary ZK calls (call it once per request instead of once per topic, if possible)

kafka git commit: KAFKA-5947; Handle authentication failure in admin client, txn producer

2017-09-21 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk f29391c49 -> 96ba21e0d KAFKA-5947; Handle authentication failure in admin client, txn producer 1. Raise AuthenticationException for authentication failures in admin client 2. Handle AuthenticationException as a fatal error for transactional

kafka git commit: MINOR: add upgrade note for KIP-173 topic configs

2017-09-21 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk a2da064cb -> f29391c49 MINOR: add upgrade note for KIP-173 topic configs Author: Damian Guy Reviewers: Matthias J. Sax , Guozhang Wang Closes #3921 from

[2/2] kafka git commit: KAFKA-5922: Add SessionWindowedKStream

2017-09-21 Thread guozhang
KAFKA-5922: Add SessionWindowedKStream Add `SessionWindowedKStream` and implementation. Deprecate existing `SessionWindow` `aggregate` methods on `KGroupedStream` Author: Damian Guy Reviewers: Bill Bejeck , Matthias J. Sax ,

kafka git commit: MINOR: Fix testUniqueErrorCodes unit test failure

2017-09-21 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 5f6393f9b -> b12ba240e MINOR: Fix testUniqueErrorCodes unit test failure Error code collision due to incorrect merge conflict resolution after 2 PRs were merged in quick succession. Author: James Cheng Reviewers: