This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 0920b79 MINOR: Add a log to print acl change notification details
new 89029ac MINOR: demote "Committing task offsets" log to DEBUG (#9489)
new 389a010 KAFKA-10689: fix windowed FKJ topology and put checks in
assignor to avoid infinite loops (#9568)
new edc940e KAFKA-10705: Make state stores not readable by others (#9583)
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../kstream/internals/graph/StreamSinkNode.java | 19 +++---
.../processor/internals/StateDirectory.java | 14 +++++
.../streams/processor/internals/StreamThread.java | 18 ++++--
.../internals/StreamsPartitionAssignor.java | 29 +++++----
.../streams/processor/internals/TaskManager.java | 2 +-
.../integration/InternalTopicIntegrationTest.java | 39 +++++++++++-
.../processor/internals/StateDirectoryTest.java | 27 +++++++++
.../internals/StreamsPartitionAssignorTest.java | 69 +++++++++++++++++++++-
9 files changed, 190 insertions(+), 29 deletions(-)
