kafka git commit: KAFKA-5862: Remove ZK dependency from Streams reset tool, Part I

2017-09-22 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 1fd70c7c9 -> 271f6b5ae KAFKA-5862: Remove ZK dependency from Streams reset tool, Part I Author: Bill Bejeck Author: bbejeck Reviewers: Matthias J. Sax , Ted Yu

kafka-site git commit: Adding New York logo to powered-by and Streams page

2017-09-22 Thread guozhang
Repository: kafka-site Updated Branches: refs/heads/asf-site aa0d8f47c -> 4bb2fd8c6 Adding New York logo to powered-by and Streams page Author: manjuapu Author: Manjula K Reviewers: Guozhang Wang Closes #85 from

kafka git commit: MINOR - Adding New York Times logo to streams page

2017-09-22 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 71a65d95a -> 1fd70c7c9 MINOR - Adding New York Times logo to streams page Author: Manjula K Author: manjuapu Reviewers: Guozhang Wang Closes #3950 from

kafka-site git commit: Adding LINE logo to Streams page

2017-09-22 Thread guozhang
Repository: kafka-site Updated Branches: refs/heads/asf-site b818b7b0c -> aa0d8f47c Adding LINE logo to Streams page guozhangwang dguy Please review. Author: Manjula K Reviewers: Guozhang Wang Closes #84 from manjuapu/asf-site Project:

kafka git commit: MINOR: Fix ClassCastException in ConsumerGroupCommand

2017-09-22 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk f4a1ca347 -> 71a65d95a MINOR: Fix ClassCastException in ConsumerGroupCommand Offset and partition are not converted from String to long and int correctly. Running the command line with --from-file option causes the following exception:

kafka git commit: MINOR: Fix ClassCastException in ConsumerGroupCommand

2017-09-22 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 f16fc68ec -> 3cda63697 MINOR: Fix ClassCastException in ConsumerGroupCommand Offset and partition are not converted from String to long and int correctly. Running the command line with --from-file option causes the following exception:

kafka git commit: KAFKA-5899: Added Connect metrics for connectors (KIP-196)

2017-09-22 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 8f90fd653 -> f4a1ca347 KAFKA-5899: Added Connect metrics for connectors (KIP-196) This PR is the first of several subtasks for [KAFKA-2376](https://issues.apache.org/jira/browse/KAFKA-2376) to add metrics to Connect worker processes. See

kafka git commit: KAFKA-5959; Fix NPE in Sender.canRetry when idempotence is not enabled

2017-09-22 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk d60f011d7 -> 8f90fd653 KAFKA-5959; Fix NPE in Sender.canRetry when idempotence is not enabled Author: Apurva Mehta Reviewers: tedyu , Jason Gustafson Closes #3947 from

kafka git commit: KAFKA-5920; Handle SSL handshake failures as authentication exceptions

2017-09-22 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk e554dc518 -> d60f011d7 KAFKA-5920; Handle SSL handshake failures as authentication exceptions 1. Propagate `SSLException` as `SslAuthenticationException` to enable clients to report these and avoid retries 2. Updates to `SslTransportLayer`

kafka git commit: KAFKA-5915; Support unmapping of mapped/direct buffers in Java 9

2017-09-22 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 125d8d6f7 -> e554dc518 KAFKA-5915; Support unmapping of mapped/direct buffers in Java 9 As mentioned in MappedByteBuffers' class documentation, its implementation was inspired by Lucene's MMapDirectory:

kafka git commit: KAFKA-5956; use serdes from materialized in table and globalTable

2017-09-22 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 7c988a3c8 -> 125d8d6f7 KAFKA-5956; use serdes from materialized in table and globalTable The new overloads `StreamBuilder.table(String, Materialized)` and `StreamsBuilder.globalTable(String, Materialized)` need to set the serdes from