kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ableegold...@apache.org
Subject [kafka] branch trunk updated (5eb8a23 -> 706f509)
Date Thu, 04 Feb 2021 02:02:41 GMT
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(-)


Mime
View raw message