This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 2367c89 KAFKA-13630: Reduce amount of time that producer network
thread holds batch queue lock (#11722)
add 28393be KAFKA-12879: Revert changes from KAFKA-12339 and instead add
retry capability to KafkaBasedLog (#11797)
No new revisions were added by this update.
Summary of changes:
.../admin/internals/MetadataOperationContext.java | 1 -
.../kafka/clients/admin/KafkaAdminClientTest.java | 42 +----
.../apache/kafka/connect/util/KafkaBasedLog.java | 27 ++-
.../org/apache/kafka/connect/util/RetryUtil.java | 101 +++++++++++
.../org/apache/kafka/connect/util/TopicAdmin.java | 29 +++-
.../kafka/connect/util/KafkaBasedLogTest.java | 14 +-
.../apache/kafka/connect/util/RetryUtilTest.java | 184 +++++++++++++++++++++
.../apache/kafka/connect/util/TopicAdminTest.java | 59 ++++++-
8 files changed, 402 insertions(+), 55 deletions(-)
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/util/RetryUtil.java
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/util/RetryUtilTest.java
