kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (294b629 -> ede0730)
Date Fri, 28 Feb 2020 20:07:27 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 294b629  throttle consumer timeout increase (#8188)
     add ede0730  KAFKA-9620: Do not throw in the middle of consumer user callbacks (#8187)

No new revisions were added by this update.

Summary of changes:
 .../consumer/internals/ConsumerCoordinator.java    |  29 ++--
 .../internals/ConsumerCoordinatorTest.java         | 158 +++++++++++++++++++--
 .../consumer/internals/MockPartitionAssignor.java  |  12 ++
 .../internals/ThrowOnAssignmentAssignor.java       |  39 +++--
 .../processor/internals/StateManagerUtil.java      |   2 +-
 .../streams/processor/internals/TaskManager.java   |  30 ++--
 .../processor/internals/TaskManagerTest.java       | 103 +++++++++++---
 7 files changed, 306 insertions(+), 67 deletions(-)
 copy streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java
=> clients/src/test/java/org/apache/kafka/clients/consumer/internals/ThrowOnAssignmentAssignor.java
(52%)


Mime
View raw message