This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from d604534cc34 MINOR; Increase log level of some rare events (#13430)
add bfd15299b1f KAFKA-14491: [14/N] Set changelog topic configs for
versioned stores (#13292)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/InternalTopicManager.java | 41 ++++++-
.../internals/InternalTopologyBuilder.java | 23 +++-
...UnwindowedUnversionedChangelogTopicConfig.java} | 12 +-
.../internals/VersionedChangelogTopicConfig.java | 112 +++++++++++++++++
.../internals/WindowedChangelogTopicConfig.java | 18 ++-
.../internals/VersionedKeyValueStoreBuilder.java | 4 +
.../processor/internals/ChangelogTopicsTest.java | 4 +-
.../internals/InternalTopicConfigTest.java | 40 +++++--
.../internals/InternalTopicManagerTest.java | 132 +++++++++++++++++----
.../internals/InternalTopologyBuilderTest.java | 39 +++++-
10 files changed, 360 insertions(+), 65 deletions(-)
rename
streams/src/main/java/org/apache/kafka/streams/processor/internals/{UnwindowedChangelogTopicConfig.java
=> UnwindowedUnversionedChangelogTopicConfig.java} (85%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/VersionedChangelogTopicConfig.java
