You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/07/21 19:21:29 UTC
[kafka] branch trunk updated (b63fecb -> 194c56f)
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 b63fecb MINOR; Move quota integration tests to using the new quota API. (#8954)
add 194c56f KAFKA-9274: Mark `retries` config as deprecated and add new `task.timeout.ms` config (#8864)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/clients/CommonClientConfigs.java | 9 ++++++-
.../kafka/clients/admin/AdminClientConfig.java | 6 +++++
.../kafka/clients/admin/KafkaAdminClient.java | 1 +
.../kafka/clients/producer/KafkaProducer.java | 1 +
.../kafka/clients/producer/ProducerConfig.java | 13 +++++++---
.../kafka/clients/admin/KafkaAdminClientTest.java | 29 ++++++++++++++++------
.../clients/consumer/RoundRobinAssignorTest.java | 2 +-
.../kafka/clients/producer/KafkaProducerTest.java | 1 +
.../connect/storage/KafkaStatusBackingStore.java | 1 +
.../main/scala/kafka/tools/ConsoleProducer.scala | 4 ++-
.../server/DynamicBrokerReconfigurationTest.scala | 1 +
.../kafka/admin/ConsumerGroupCommandTest.scala | 2 ++
.../unit/kafka/server/LogDirFailureTest.scala | 3 +++
.../test/scala/unit/kafka/utils/TestUtils.scala | 4 ++-
docs/streams/upgrade-guide.html | 8 ++++++
docs/upgrade.html | 10 ++++++++
.../kafka/log4jappender/KafkaLog4jAppender.java | 1 +
.../org/apache/kafka/streams/StreamsConfig.java | 25 ++++++++++++++++++-
.../internals/GlobalStateManagerImpl.java | 1 +
.../processor/internals/InternalTopicManager.java | 1 +
.../apache/kafka/streams/StreamsConfigTest.java | 26 +++++++++++++++++--
.../integration/AbstractResetIntegrationTest.java | 7 +++---
.../integration/InternalTopicIntegrationTest.java | 7 +++---
...bleForeignKeyInnerJoinMultiIntegrationTest.java | 8 +++---
.../internals/GlobalStateManagerImplTest.java | 12 +++++----
.../internals/InternalTopicManagerTest.java | 1 +
.../tests/StreamsBrokerDownResilienceTest.java | 6 +++--
.../kafka/streams/tests/StreamsOptimizedTest.java | 2 +-
.../streams/tests/StreamsStandByReplicaTest.java | 2 ++
.../apache/kafka/streams/scala/WordCountTest.scala | 1 -
...StreamToTableJoinScalaIntegrationTestBase.scala | 2 --
.../org/apache/kafka/tools/VerifiableProducer.java | 1 +
32 files changed, 156 insertions(+), 42 deletions(-)