kafka git commit: MINOR: Make Kafka Connect step in quickstart more Windows friendly

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk ad6c53d89 -> beb0ad9bb MINOR: Make Kafka Connect step in quickstart more Windows friendly Author: Vahid Hashemian Reviewers: Ewen Cheslack-Postava Closes #2498 from vahidhashemian/doc/connect_quickstart_update Project: http://git-wip-u

kafka git commit: KAFKA-5468: WorkerSourceTask offset commit loglevel changes

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk cd207dd3f -> ad6c53d89 KAFKA-5468: WorkerSourceTask offset commit loglevel changes changed log level for source connector worker task when committing offsets Author: Stephane Maarek Reviewers: Ewen Cheslack-Postava Closes #3367 from sim

kafka git commit: KAFKA-5431; cleanSegments should not set length for cleanable segment files

2017-07-20 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.11.0 20adcbd8a -> 67fbe049d KAFKA-5431; cleanSegments should not set length for cleanable segment files For a compacted topic with preallocate enabled, during log cleaning, LogCleaner.cleanSegments does not have to pre-allocate the underlying f

kafka git commit: KAFKA-5431; cleanSegments should not set length for cleanable segment files

2017-07-20 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 1d2d0bac9 -> cd207dd3f KAFKA-5431; cleanSegments should not set length for cleanable segment files For a compacted topic with preallocate enabled, during log cleaning, LogCleaner.cleanSegments does not have to pre-allocate the underlying fi

kafka git commit: MINOR: Fixed misleading reference to HTTPS instead of SSL support in the doc

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.11.0 3b00f8b83 -> 20adcbd8a MINOR: Fixed misleading reference to HTTPS instead of SSL support in the doc Author: ppatierno Reviewers: Ewen Cheslack-Postava Closes #3487 from ppatierno/ssl-doc-https (cherry picked from commit 1d2d0bac9ea61de

kafka git commit: MINOR: Fixed misleading reference to HTTPS instead of SSL support in the doc

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 8a8156621 -> 1d2d0bac9 MINOR: Fixed misleading reference to HTTPS instead of SSL support in the doc Author: ppatierno Reviewers: Ewen Cheslack-Postava Closes #3487 from ppatierno/ssl-doc-https Project: http://git-wip-us.apache.org/repo

kafka git commit: KAFKA-5410; Fix taskClass() method name in Connector and flush() signature in SinkTask

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 9ae09e805 -> 8a8156621 KAFKA-5410; Fix taskClass() method name in Connector and flush() signature in SinkTask Author: ppatierno Reviewers: Ewen Cheslack-Postava Closes #3269 from ppatierno/connect-doc Project: http://git-wip-us.apache

kafka git commit: KAFKA-5410; Fix taskClass() method name in Connector and flush() signature in SinkTask

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.11.0 b0ff6ea9a -> 3b00f8b83 KAFKA-5410; Fix taskClass() method name in Connector and flush() signature in SinkTask Author: ppatierno Reviewers: Ewen Cheslack-Postava Closes #3269 from ppatierno/connect-doc (cherry picked from commit 8a8156

kafka git commit: KAFKA-5623: ducktape kafka service: do not assume Service contains num_nodes

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.11.0 930eefdab -> b0ff6ea9a KAFKA-5623: ducktape kafka service: do not assume Service contains num_nodes …m_nodes Author: Colin P. Mccabe Reviewers: Ewen Cheslack-Postava Closes #3557 from cmccabe/KAFKA-5623 (cherry picked from commit 9a

kafka git commit: KAFKA-5623: ducktape kafka service: do not assume Service contains num_nodes

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.10.2 c1e202619 -> 97b24d820 KAFKA-5623: ducktape kafka service: do not assume Service contains num_nodes …m_nodes Author: Colin P. Mccabe Reviewers: Ewen Cheslack-Postava Closes #3557 from cmccabe/KAFKA-5623 (cherry picked from commit 9a

kafka git commit: KAFKA-5623: ducktape kafka service: do not assume Service contains num_nodes

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 5bb53e034 -> 9ae09e805 KAFKA-5623: ducktape kafka service: do not assume Service contains num_nodes …m_nodes Author: Colin P. Mccabe Reviewers: Ewen Cheslack-Postava Closes #3557 from cmccabe/KAFKA-5623 Project: http://git-wip-us.ap

kafka git commit: KAFKA-5534; KafkaConsumer `offsetForTimes` result should include partitions with no offset

2017-07-20 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk cdff011fe -> 5bb53e034 KAFKA-5534; KafkaConsumer `offsetForTimes` result should include partitions with no offset For topics that support timestamp search, if no offset is found for a partition, the partition should still be included in th

kafka git commit: KAFKA-5610; WriteTxnMarker handler should return UNKNOWN_TOPIC_OR_PARTITION if replica is not available

2017-07-20 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.11.0 8ebe41175 -> 930eefdab KAFKA-5610; WriteTxnMarker handler should return UNKNOWN_TOPIC_OR_PARTITION if replica is not available Before this patch, we would instead return the non-retriable `UNSUPPORTED_FOR_MESSAGE_FORMAT` causing markers t

kafka git commit: KAFKA-5610; WriteTxnMarker handler should return UNKNOWN_TOPIC_OR_PARTITION if replica is not available

2017-07-20 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 9b7a6ee2a -> cdff011fe KAFKA-5610; WriteTxnMarker handler should return UNKNOWN_TOPIC_OR_PARTITION if replica is not available Before this patch, we would instead return the non-retriable `UNSUPPORTED_FOR_MESSAGE_FORMAT` causing markers to

kafka git commit: MINOR: Apply extra serialized rsync step to both parallel and serial paths

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.10.1 9b7af79a1 -> bafdc980a MINOR: Apply extra serialized rsync step to both parallel and serial paths Author: Ewen Cheslack-Postava Reviewers: Ismael Juma , Eno Thereska Closes #3546 from ewencp/fix-rsync (cherry picked from commit 9b7a6e

kafka git commit: MINOR: Apply extra serialized rsync step to both parallel and serial paths

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.10.0 f7e5f70e4 -> 32c086317 MINOR: Apply extra serialized rsync step to both parallel and serial paths Author: Ewen Cheslack-Postava Reviewers: Ismael Juma , Eno Thereska Closes #3546 from ewencp/fix-rsync (cherry picked from commit 9b7a6e

kafka git commit: MINOR: Apply extra serialized rsync step to both parallel and serial paths

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.10.2 021960be8 -> c1e202619 MINOR: Apply extra serialized rsync step to both parallel and serial paths Author: Ewen Cheslack-Postava Reviewers: Ismael Juma , Eno Thereska Closes #3546 from ewencp/fix-rsync (cherry picked from commit 9b7a6e

kafka git commit: MINOR: Apply extra serialized rsync step to both parallel and serial paths

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/0.11.0 4b968afef -> 8ebe41175 MINOR: Apply extra serialized rsync step to both parallel and serial paths Author: Ewen Cheslack-Postava Reviewers: Ismael Juma , Eno Thereska Closes #3546 from ewencp/fix-rsync (cherry picked from commit 9b7a6e

kafka git commit: MINOR: Apply extra serialized rsync step to both parallel and serial paths

2017-07-20 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk b04bed022 -> 9b7a6ee2a MINOR: Apply extra serialized rsync step to both parallel and serial paths Author: Ewen Cheslack-Postava Reviewers: Ismael Juma , Eno Thereska Closes #3546 from ewencp/fix-rsync Project: http://git-wip-us.apache

kafka git commit: KAFKA-3856; Cleanup Kafka Stream builder API (KIP-120)

2017-07-20 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk e0099e1f5 -> b04bed022 KAFKA-3856; Cleanup Kafka Stream builder API (KIP-120) Author: Matthias J. Sax Reviewers: Damian Guy , Bill Bejeck Closes #2301 from mjsax/kafka-3856-topology-builder-API Project: http://git-wip-us.apache.org/rep

kafka git commit: KAFKA-5556; Fix IllegalStateException in KafkaConsumer.commitSync due to missing future completion check

2017-07-20 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.11.0 2452201c5 -> 4b968afef KAFKA-5556; Fix IllegalStateException in KafkaConsumer.commitSync due to missing future completion check This PR makes `commitOffsetsSync` method check whether future is completed after client's poll or not. Author

kafka git commit: KAFKA-5556; Fix IllegalStateException in KafkaConsumer.commitSync due to missing future completion check

2017-07-20 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk fe4a469fc -> e0099e1f5 KAFKA-5556; Fix IllegalStateException in KafkaConsumer.commitSync due to missing future completion check This PR makes `commitOffsetsSync` method check whether future is completed after client's poll or not. Author:

kafka git commit: KAFKA-4830; Augment KStream.print() to allow users pass in extra parameters in the printed string

2017-07-20 Thread damianguy
Repository: kafka Updated Branches: refs/heads/trunk 84d2b6a01 -> fe4a469fc KAFKA-4830; Augment KStream.print() to allow users pass in extra parameters in the printed string I extend `KStream#print()` to `KStream#print(KeyValueMapper)`. So I add the following methods : 1. `KStream#print(KeyVa

kafka git commit: MINOR: Simplify SensorAccess usage

2017-07-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 272956f03 -> 84d2b6a01 MINOR: Simplify SensorAccess usage I was investigating an exception in this code and found a few opportunities for making it clearer. I also added the `out` folder to `.gitignore` as IntelliJ sometimes uses that as th

kafka git commit: KAFKA-5134; Replace zkClient.getChildren method with zkUtils.getChildren

2017-07-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 0816e47bf -> 272956f03 KAFKA-5134; Replace zkClient.getChildren method with zkUtils.getChildren Author: Balint Molnar Reviewers: Ismael Juma Closes #3097 from baluchicken/KAFKA-5134-2 Project: http://git-wip-us.apache.org/repos/asf/kaf

kafka git commit: MINOR: Docs update, Java clients use Kafka Metrics

2017-07-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 1b8aed6dc -> 0816e47bf MINOR: Docs update, Java clients use Kafka Metrics This contribution is my original work and I license the work to the project under the project's open source license. Author: Jeff Klukas Reviewers: Ismael Juma C

kafka git commit: MINOR: Docs update, Java clients use Kafka Metrics

2017-07-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 a6c108d3b -> 2452201c5 MINOR: Docs update, Java clients use Kafka Metrics This contribution is my original work and I license the work to the project under the project's open source license. Author: Jeff Klukas Reviewers: Ismael Juma

kafka git commit: MINOR: Implement ConfigEntry.toString()

2017-07-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 acfcc1f91 -> a6c108d3b MINOR: Implement ConfigEntry.toString() Author: Paolo Patierno Reviewers: Manikumar Reddy , Ismael Juma Closes #3551 from ppatierno/admin_config_entry (cherry picked from commit 1b8aed6dc52e5d2f7ba29e4589baf15d5

kafka git commit: MINOR: Implement ConfigEntry.toString()

2017-07-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 43aa14f2d -> 1b8aed6dc MINOR: Implement ConfigEntry.toString() Author: Paolo Patierno Reviewers: Manikumar Reddy , Ismael Juma Closes #3551 from ppatierno/admin_config_entry Project: http://git-wip-us.apache.org/repos/asf/kafka/repo C

kafka git commit: MINOR: Clarify wording in server.properties comment

2017-07-20 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk f50af9c31 -> 43aa14f2d MINOR: Clarify wording in server.properties comment Author: Jeff Widman Reviewers: Ismael Juma Closes #2851 from jeffwidman/patch-3 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wi