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 e0824e2 MINOR: Just one put and flush to generation rocksDB File in
RocksDBStoreTest (#7469)
add fb9b0df MINOR: Augment log4j to add generation number in
performAssign (#7451)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/AbstractCoordinator.java | 66 ++++++++++++++--------
.../consumer/internals/ConsumerCoordinator.java | 11 ++--
.../internals/AbstractCoordinatorTest.java | 2 +-
.../internals/ConsumerCoordinatorTest.java | 6 +-
.../runtime/distributed/WorkerCoordinator.java | 2 +-
5 files changed, 52 insertions(+), 35 deletions(-)
