This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 6b08905 KAFKA-3978; Ensure high watermark is always
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 77137e9 KAFKA-3978; Ensure high watermark is always
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 882b0ec KAFKA-3978; Ensure high watermark is always
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new d2bbcbe MINOR: Correct "exeption" to &quo
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new d935699 KAFKA-6640; Improve efficiency of
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new a3c7031 KAFKA-6640; Improve efficiency of
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 5cdb951 KAFKA-6653; Complete delayed operations
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 821ec7b KAFKA-6653; Complete delayed operations even
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 372b4c6 KAFKA-6656; Config tool should return non
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 5f365e5 KAFKA-6656; Config tool should return non-zero
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new ca83677 KAFKA-6656; Config tool should return non-zero
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new a70e4f9 KAFKA-6658; Fix RoundTripWorkload and make
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 9782465 KAFKA-6672; ConfigCommand should create
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new d018637 KAFKA-6672; ConfigCommand should create config
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 2afac71 MINOR: Remove unnecessary null checks
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 5e9557a KAFKA-6672; ConfigCommand should create config
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 2b236f9 MINOR: Use large batches in metrics test for
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new ae31ee6 KAFKA-6530: Use actual first offset of
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4391a42 MINOR: Use log start offset as high
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new c120bd7 MINOR: Use log start offset as high watermark
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 7e594ee MINOR: Use log start offset as high watermark
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new e520589 KAFKA-6676: Ensure Kafka chroot exists in
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 27bb3cc MINOR: KafkaFutureImpl#addWaiter should be
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new fcc03c0 MINOR: KafkaFutureImpl#addWaiter should be
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 2f90cb8 MINOR: Remove acceptor creation in network
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 67afbd2 MINOR: Remove acceptor creation in network
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 62ee1fd KAFKA-6683; Ensure producer state not mutated
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new dd78b9f KAFKA-6637; Avoid divide by zero error with
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 549a5ce MINOR: Fix potential resource leak in
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 3e14caa MINOR: Fix potential resource leak in
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 355a8d8 MINOR: Fix potential resource leak in
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 514936a MINOR: Remove redundant initialization of
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 3f61104 KAFKA-6052; Fix WriteTxnMarkers request
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 89b2df9 KAFKA-6052; Fix WriteTxnMarkers request retry
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new a6c8259 KAFKA-6052; Fix WriteTxnMarkers request retry
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 9eb32ea KAFKA-6446; KafkaProducer initTransactions
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 395c7e0 MINOR: Fix
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 5bdfbd1 MINOR: Fix
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 911259e MINOR: Fix
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 9baa9bd MINOR: Update Jackson to 2.9.5 (#4776
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new dd70117 KAFKA-6724; ConsumerPerformance should not
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8662a02 MINOR: Fix partition loading checks in
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 1dc3027 KAFKA-5674; Reduce max.connections.per.ip
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 719a21f KAFKA-6739; Ignore headers when down
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 3cc6a67 KAFKA-6739; Ignore headers when down-converting
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 3738ffe KAFKA-6739; Ignore headers when down-converting
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 53d4267 MINOR: Don’t send the DeleteTopicsRequest
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new ed2f10e MINOR: Update
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 0a8f35b KAFKA-6768; Transactional producer may hang
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 83a9e04 MINOR: Fix doc - `FileMessageSet` was
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 7421f9d KAFKA-6773; Allow offset commit/fetch
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new fb3a948 MINOR: Disable failing
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 886daf5 KAFKA-6234; Increased timeout value for
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new f3ed56b MINOR: Mention that -1 disables retention
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new d305027 MINOR: Mention that -1 disables retention by
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 19418fc KAFKA-6514; Add API version as a tag for
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 432c82d KAFKA-6727; Fix broken Config hashCode
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4013767 MINOR: Log the exception thrown by
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8350340 KAFKA-6770; Add New Protocol Versions to
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/kafka-site.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 71c82a4 MINOR: Add list of 1.1 protocol
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 52e9ba6 MINOR: Add line break so example command is
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4623422 KAFKA-3365; Add documentation method for
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new f2514e6 MINOR: Fix kafka-run-class for Java 10
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 9e062b3e MINOR: Use distinct consumer groups in
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new d9e804b MINOR: Clarify meaning of end offset in
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 35c75ea MINOR: Fix formatting in --new-consumer
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 3bc2575 MINOR: Disabled flaky
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 6be908a MINOR: Refactor AdminClient
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new ff1875f KAFKA-6778; AdminClient.describeConfigs
Repository: kafka
Updated Branches:
refs/heads/0.11.0 5819a364c -> c63919c27
KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0
Author: Stephane Roset
Reviewers: Ismael Juma , Jason Gustafson
Closes #3442 from rosets/KAFKA-5512
(cherry picked from commit 4a7064d
Repository: kafka
Updated Branches:
refs/heads/trunk 08b775c32 -> 4a7064d1a
KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0
Author: Stephane Roset
Reviewers: Ismael Juma , Jason Gustafson
Closes #3442 from rosets/KAFKA-5512
Project: http://git-wip-us.apache.
Repository: kafka
Updated Branches:
refs/heads/trunk 5effe7239 -> 3620035c4
KAFKA-5611; AbstractCoordinator should handle wakeup raised from onJoinComplete
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #3571 from hachikuji/KAFKA-5611
Project: http://git-wip-us.apache.org/repos/as
Repository: kafka
Updated Branches:
refs/heads/0.11.0 c1f583e67 -> 25bcc2176
KAFKA-5611; AbstractCoordinator should handle wakeup raised from onJoinComplete
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #3571 from hachikuji/KAFKA-5611
(cherry picked from commit 3620035c45736b74e69
Repository: kafka
Updated Branches:
refs/heads/trunk 9d6020ec5 -> 6bd730264
KAFKA-5634; Do not allow segment deletion beyond high watermark
This patch changes the segment deletion behavior to take the high watermark of
the partition into account. In particular, segments containing offsets equ
Repository: kafka
Updated Branches:
refs/heads/0.11.0 25bcc2176 -> c2b939c62
KAFKA-5634; Do not allow segment deletion beyond high watermark
This patch changes the segment deletion behavior to take the high watermark of
the partition into account. In particular, segments containing offsets eq
Repository: kafka
Updated Branches:
refs/heads/trunk da2205578 -> cd4c6c018
KAFKA-5630; Consumer should block on corrupt records and keep throwing an
exception
This patch handles the case that a CorruptRecordException is thrown from the
iterator directly.
The fix is a little tricky as except
Repository: kafka
Updated Branches:
refs/heads/0.11.0 37ada7957 -> 86bfbd0ce
KAFKA-5630; Consumer should block on corrupt records and keep throwing an
exception
This patch handles the case that a CorruptRecordException is thrown from the
iterator directly.
The fix is a little tricky as excep
Repository: kafka
Updated Branches:
refs/heads/0.11.0 86bfbd0ce -> 7e0ec9c76
MINOR: Request log should be enabled by debug level
At some point, we lost the ability to output request
logging at debug level (which is a little less
verbose than at trace level).
Author: Ismael Juma
Reviewers: J
Repository: kafka
Updated Branches:
refs/heads/trunk cd4c6c018 -> 4086db472
MINOR: Request log should be enabled by debug level
At some point, we lost the ability to output request
logging at debug level (which is a little less
verbose than at trace level).
Author: Ismael Juma
Reviewers: Ja
Repository: kafka
Updated Branches:
refs/heads/trunk 6bee1e9e5 -> 13deb84dc
MINOR: Null out all buffer references in RequestChannel.Request
The previous code kept two references to `Buffer` and only nulled
out one of them.
As part of this, I removed the `case` modifier from
`RequestChannel.{R
Repository: kafka
Updated Branches:
refs/heads/trunk 613971f8d -> 5a516fb28
KAFKA-2507 KAFKA-2959; Remove legacy ControlledShutdown request/response objects
This patch replaces the legacy ControlledShutdown objects in `kafka.api` with
the alternatives in `org.apache.kafka.common.requests`. Si
Repository: kafka
Updated Branches:
refs/heads/trunk 22611aca9 -> 70796c3ca
MINOR: Fix error response handler for controlled shutdown v0
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #3627 from hachikuji/minor-fix-controlled-shutdown-error-response
Project: http://git-wip-us.apac
Repository: kafka
Updated Branches:
refs/heads/trunk c35c47981 -> 1ad74f5b7
KAFKA-5629; ConsoleConsumer should respect auto.offset.reset if specified on
the command line
when "auto.offset.reset" property is specified on the command line but
overridden by the code during startup. Currently th
Repository: kafka
Updated Branches:
refs/heads/trunk 75b0f30c4 -> 017a21c60
MINOR: Remove unneeded error handlers in deprecated request objects
These handlers were previously used on the broker to handle uncaught
exceptions, but now the broker users the new Java request objects exclusively.
Repository: kafka
Updated Branches:
refs/heads/trunk c0f7a7705 -> 869ef5579
HOTFIX: ConsoleConsumer using wrong old consumer config value for
auto.offset.reset
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #3665 from hachikuji/hotfix-auto-reset-console-consumer
Project: http://g
Repository: kafka
Updated Branches:
refs/heads/trunk 869ef5579 -> 3b1cea60e
KAFKA-5731; Corrected how the sink task worker updates the last committed
offsets
Prior to this change, it was possible for the synchronous consumer commit
request to be handled before previously-submitted asynchrono
Repository: kafka
Updated Branches:
refs/heads/0.11.0 a1a118606 -> 22c9a8cb4
KAFKA-5731; Corrected how the sink task worker updates the last committed
offsets (0.11.0)
Prior to this change, it was possible for the synchronous consumer commit
request to be handled before previously-submitted
Repository: kafka
Updated Branches:
refs/heads/trunk efe4f6540 -> 334a30bcf
KAFKA-5730; Consumer should invoke async commit callback before sync commit
returns
Author: Jason Gustafson
Reviewers: Randall Hauch , Ewen Cheslack-Postava
Closes #3666 from hachikuji/KAFKA-5730
Project: http:
Repository: kafka
Updated Branches:
refs/heads/trunk ed96523a2 -> 6896f1ddb
http://git-wip-us.apache.org/repos/asf/kafka/blob/6896f1dd/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java
--
MINOR: Ensure consumer logging has clientId/groupId context
This patch ensures that the consumer groupId and clientId are available in all
log messages which makes debugging much easier when a single application has
multiple consumer instances. To make this easier, I've added a new `LogContext`
Repository: kafka
Updated Branches:
refs/heads/trunk 8a5a84dc6 -> bf3bfd674
KAFKA-5747; Producer snapshot loading should cover schema errors
Author: Jason Gustafson
Reviewers: Apurva Mehta , Ismael Juma
Closes #3688 from hachikuji/KAFKA-5747
Project: http://git-wip-us.apache.org/repos/as
Repository: kafka
Updated Branches:
refs/heads/0.11.0 fbd41d64d -> b4f3345b5
KAFKA-5747; Producer snapshot loading should cover schema errors
Author: Jason Gustafson
Reviewers: Apurva Mehta , Ismael Juma
Closes #3688 from hachikuji/KAFKA-5747
(cherry picked from commit bf3bfd6749610eb49a4
Repository: kafka
Updated Branches:
refs/heads/trunk 99eebc840 -> 5b99a288c
KAFKA-5644; Fix Reset Consumer Group Offset tool to handle minute component of
TimeZone
Author: Manikumar Reddy
Reviewers: Jason Gustafson
Closes #3626 from omkreddy/KAFKA-5644
Project: http://git-wip-us.apache.
Repository: kafka
Updated Branches:
refs/heads/0.11.0 e47f2d3c4 -> d77c057dd
KAFKA-5644; Fix Reset Consumer Group Offset tool to handle minute component of
TimeZone
Author: Manikumar Reddy
Reviewers: Jason Gustafson
Closes #3626 from omkreddy/KAFKA-5644
(cherry picked from commit 5b99a28
Repository: kafka
Updated Branches:
refs/heads/trunk 21fea170d -> 71417552c
KAFKA-5342; Clarify producer fatal/abortable errors and fix inconsistencies
This patch improves documentation on the handling of errors for the
idempotent/transactional producer. It also fixes a couple minor inconsist
Repository: kafka
Updated Branches:
refs/heads/0.11.0 b872abf69 -> 6e5f8850d
KAFKA-5342; Clarify producer fatal/abortable errors and fix inconsistencies
This patch improves documentation on the handling of errors for the
idempotent/transactional producer. It also fixes a couple minor inconsis
Repository: kafka
Updated Branches:
refs/heads/trunk 05e3850b2 -> c4d629a0b
http://git-wip-us.apache.org/repos/asf/kafka/blob/c4d629a0/core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala
--
diff --git a/core/src/test/s
MINOR: Consolidate broker request/response handling
This patch contains a few small improvements to make request/response handling
more consistent. Primarily it consolidates request/response serialization logic
so that `SaslServerAuthenticator` and `KafkaApis` follow the same path. It also
redu
http://git-wip-us.apache.org/repos/asf/kafka/blob/c4d629a0/core/src/main/scala/kafka/network/RequestChannel.scala
--
diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala
b/core/src/main/scala/kafka/network/RequestCh
Repository: kafka
Updated Branches:
refs/heads/trunk c4d629a0b -> 607c3c21f
KAFKA-5755; KafkaProducer should be refactored to use LogContext
With LogContext, each producer log item is automatically prefixed with client
id and transactional id.
Author: huxihx
Reviewers: Jason Gustafson
Cl
701 - 800 of 2281 matches
Mail list logo
