This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from eb01221dc00 KAFKA-17125: Streams Sticky Task Assignor (#18652)
add bf05d2c9143 KAFKA-18672; CoordinatorRecordSerde must validate value
version (#18749)
No new revisions were added by this update.
Summary of changes:
.../common/runtime/CoordinatorLoader.java | 17 ----------
.../common/runtime/CoordinatorRecordSerde.java | 5 +++
.../coordinator/common/runtime/Deserializer.java | 36 ++++++++++++++++++++++
.../coordinator/group/CoordinatorLoaderImpl.scala | 3 +-
.../main/scala/kafka/tools/DumpLogSegments.scala | 2 +-
.../group/CoordinatorLoaderImplTest.scala | 2 +-
.../group/GroupCoordinatorRecordSerde.java | 5 ++-
.../group/GroupCoordinatorRecordSerdeTest.java | 34 ++++++++++++++++++--
.../share/ShareCoordinatorRecordSerde.java | 5 ++-
.../share/ShareCoordinatorRecordSerdeTest.java | 6 ++--
.../TransactionCoordinatorRecordSerde.java | 5 ++-
.../TransactionCoordinatorRecordSerdeTest.java | 6 ++--
12 files changed, 88 insertions(+), 38 deletions(-)
