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%)
