You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rs...@apache.org on 2020/06/30 11:16:17 UTC
[kafka] branch trunk updated (89c6562 -> 55b5b24)

This is an automated email from the ASF dual-hosted git repository.

rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 89c6562  make produce-sync flush (#8925)
     add 55b5b24  KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch (KIP-601) (#8683)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/ClusterConnectionStates.java     | 132 +++++++++++++++++----
 .../apache/kafka/clients/CommonClientConfigs.java  |   8 ++
 .../org/apache/kafka/clients/NetworkClient.java    |  52 +++++++-
 .../kafka/clients/admin/AdminClientConfig.java     |  16 +++
 .../kafka/clients/admin/KafkaAdminClient.java      |   2 +
 .../kafka/clients/consumer/ConsumerConfig.java     |  16 +++
 .../kafka/clients/consumer/KafkaConsumer.java      |   2 +
 .../kafka/clients/producer/KafkaProducer.java      |   2 +
 .../kafka/clients/producer/ProducerConfig.java     |  16 +++
 .../kafka/common/utils/ExponentialBackoff.java     |  53 +++++++++
 .../kafka/clients/ClusterConnectionStatesTest.java |  52 +++++++-
 .../apache/kafka/clients/NetworkClientTest.java    |  62 +++++++++-
 .../clients/consumer/internals/FetcherTest.java    |   2 +-
 .../clients/producer/internals/SenderTest.java     |   2 +-
 .../kafka/common/utils/ExponentialBackoffTest.java |  38 +++---
 .../java/org/apache/kafka/test/MockSelector.java   |  12 ++
 .../runtime/distributed/DistributedConfig.java     |  12 ++
 .../runtime/distributed/WorkerGroupMember.java     |   2 +
 .../kafka/admin/BrokerApiVersionsCommand.scala     |  18 +++
 .../controller/ControllerChannelManager.scala      |   2 +
 .../TransactionMarkerChannelManager.scala          |   2 +
 core/src/main/scala/kafka/server/KafkaConfig.scala |  10 ++
 core/src/main/scala/kafka/server/KafkaServer.scala |   2 +
 .../kafka/server/ReplicaFetcherBlockingSend.scala  |   2 +
 .../kafka/tools/ReplicaVerificationTool.scala      |   2 +
 .../scala/unit/kafka/server/KafkaConfigTest.scala  |   2 +
 .../trogdor/workload/ConnectionStressWorker.java   |   2 +
 27 files changed, 469 insertions(+), 54 deletions(-)
 create mode 100644 clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java
 copy connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorTypeTest.java => clients/src/test/java/org/apache/kafka/common/utils/ExponentialBackoffTest.java (52%)