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