This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 5eb8a23 KAFKA-12270: Handle race condition when Connect tasks attempt
to create topics (#10032)
add 706f509 KAFKA-10716: persist UUID in state directory for stable
processId across restarts (#9978)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 160 +++++++-----
.../processor/internals/StateDirectory.java | 122 ++++++++-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 3 +
.../KStreamRepartitionIntegrationTest.java | 19 +-
...bleForeignKeyInnerJoinMultiIntegrationTest.java | 45 ++--
.../integration/StandbyTaskEOSIntegrationTest.java | 273 +++++++++++----------
.../integration/StoreUpgradeIntegrationTest.java | 18 +-
.../integration/utils/IntegrationTestUtils.java | 11 +
.../processor/internals/StateDirectoryTest.java | 82 ++++++-
9 files changed, 499 insertions(+), 234 deletions(-)
