You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2020/01/31 18:21:54 UTC

[kafka] branch trunk updated (72232df -> c8d97c6)

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

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


    from 72232df  MINOR: Introduce 2.5-IV0 IBP (#8010)
     add c8d97c6  KAFKA-9375: Add names to all Connect threads (#7901)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/common/utils}/ThreadUtils.java    |  2 +-
 .../apache/kafka/common/utils/ThreadUtilsTest.java | 89 ++++++++++++++++++++++
 .../org/apache/kafka/connect/mirror/Scheduler.java |  2 +-
 .../connect/runtime/SourceTaskOffsetCommitter.java |  4 +-
 .../runtime/distributed/DistributedHerder.java     | 23 +++---
 .../connect/storage/MemoryOffsetBackingStore.java  |  4 +-
 .../runtime/distributed/DistributedHerderTest.java | 17 +++++
 .../storage/FileOffsetBackingStoreTest.java        | 10 +++
 .../apache/kafka/trogdor/agent/WorkerManager.java  |  2 +-
 .../kafka/trogdor/coordinator/NodeManager.java     |  2 +-
 .../kafka/trogdor/coordinator/TaskManager.java     |  2 +-
 .../apache/kafka/trogdor/rest/JsonRestServer.java  |  2 +-
 .../trogdor/workload/ConnectionStressWorker.java   |  2 +-
 .../kafka/trogdor/workload/ConsumeBenchWorker.java |  2 +-
 .../trogdor/workload/ExternalCommandWorker.java    |  2 +-
 .../kafka/trogdor/workload/ProduceBenchWorker.java |  2 +-
 .../kafka/trogdor/workload/RoundTripWorker.java    |  2 +-
 .../workload/SustainedConnectionWorker.java        |  2 +-
 .../kafka/trogdor/common/MiniTrogdorCluster.java   |  1 +
 .../kafka/trogdor/task/SampleTaskWorker.java       |  2 +-
 20 files changed, 149 insertions(+), 25 deletions(-)
 rename {tools/src/main/java/org/apache/kafka/trogdor/common => clients/src/main/java/org/apache/kafka/common/utils}/ThreadUtils.java (98%)
 create mode 100644 clients/src/test/java/org/apache/kafka/common/utils/ThreadUtilsTest.java