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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
30 matches
Mail list logo