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 e57973b KAFKA-12417: streams copyDependentLibs should not copy
testRuntime configuration jars (#10466)
add 3805f37 KAFKA-12574: KIP-732, Deprecate eos-alpha and replace
eos-beta with eos-v2 (#10573)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 8 +-
.../kafka/clients/producer/KafkaProducer.java | 18 ++-
.../kafka/clients/producer/MockProducer.java | 17 +--
.../apache/kafka/clients/producer/Producer.java | 1 +
.../kafka/clients/producer/KafkaProducerTest.java | 2 +-
.../kafka/clients/producer/MockProducerTest.java | 20 +--
.../kafka/api/AuthorizerIntegrationTest.scala | 6 +-
.../kafka/api/TransactionsBounceTest.scala | 2 +
.../integration/kafka/api/TransactionsTest.scala | 10 +-
docs/streams/core-concepts.html | 6 +-
docs/streams/developer-guide/config-streams.html | 17 +--
docs/streams/upgrade-guide.html | 28 +++--
docs/upgrade.html | 7 ++
release.py | 2 +-
.../org/apache/kafka/streams/StreamsConfig.java | 49 ++++++--
.../processor/internals/ActiveTaskCreator.java | 10 +-
.../streams/processor/internals/StreamThread.java | 32 ++---
.../processor/internals/StreamsProducer.java | 23 ++--
.../streams/processor/internals/TaskManager.java | 10 +-
.../apache/kafka/streams/StreamsConfigTest.java | 137 ++++++++++++++++++++-
.../EOSUncleanShutdownIntegrationTest.java | 3 +-
.../streams/integration/EosIntegrationTest.java | 3 +-
...nTest.java => EosV2UpgradeIntegrationTest.java} | 85 ++++++-------
.../GlobalKTableEOSIntegrationTest.java | 4 +-
.../KTableSourceTopicRestartIntegrationTest.java | 5 +-
.../ResetPartitionTimeIntegrationTest.java | 3 +-
.../integration/RocksDBMetricsIntegrationTest.java | 3 +-
.../integration/StandbyTaskEOSIntegrationTest.java | 3 +-
.../SuppressionDurabilityIntegrationTest.java | 4 +-
.../processor/internals/ActiveTaskCreatorTest.java | 46 ++++---
.../processor/internals/RecordCollectorTest.java | 23 ++--
.../processor/internals/StandbyTaskTest.java | 5 +-
.../processor/internals/StreamTaskTest.java | 11 +-
.../processor/internals/StreamThreadTest.java | 47 ++++++-
.../processor/internals/StreamsProducerTest.java | 16 +--
.../processor/internals/TaskManagerTest.java | 20 +--
.../streams/tests/BrokerCompatibilityTest.java | 2 +-
.../apache/kafka/streams/tests/StreamsEosTest.java | 7 +-
.../kafka/streams/tests/StreamsSmokeTest.java | 11 +-
.../apache/kafka/streams/TopologyTestDriver.java | 7 +-
.../kafka/streams/TopologyTestDriverEosTest.java | 2 +-
.../kafka/tools/TransactionalMessageCopier.java | 8 +-
42 files changed, 495 insertions(+), 228 deletions(-)
rename
streams/src/test/java/org/apache/kafka/streams/integration/{EosBetaUpgradeIntegrationTest.java
=> EosV2UpgradeIntegrationTest.java} (95%)
