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(-)