You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2021/02/12 23:14:15 UTC
[kafka] branch 2.8 updated (f4e475c -> 6c00d8e)

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

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


    from f4e475c  MINOR: Revert AdminClient changes for DeleteTopics (#10121)
     add 91fa677  Revert "KAFKA-10867: Improved task idling (#9840)"
     add 6c00d8e  Revert "KAFKA-10866: Add metadata to ConsumerRecords (#9836)"

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/consumer/ConsumerRecords.java    | 103 +-------
 .../kafka/clients/consumer/KafkaConsumer.java      |   7 +-
 .../kafka/clients/consumer/MockConsumer.java       |  17 +-
 .../clients/consumer/internals/FetchedRecords.java | 102 --------
 .../kafka/clients/consumer/internals/Fetcher.java  |  45 ++--
 .../consumer/internals/SubscriptionState.java      |  12 -
 .../kafka/clients/consumer/KafkaConsumerTest.java  | 137 +----------
 .../clients/consumer/internals/FetcherTest.java    |  28 +--
 .../kafka/api/PlaintextConsumerTest.scala          |  36 +--
 .../org/apache/kafka/streams/StreamsConfig.java    |   1 -
 .../processor/internals/ActiveTaskCreator.java     |   3 +-
 .../processor/internals/PartitionGroup.java        | 148 +-----------
 .../streams/processor/internals/StandbyTask.java   |   6 -
 .../streams/processor/internals/StreamTask.java    |  68 +++---
 .../streams/processor/internals/StreamThread.java  |  12 +-
 .../kafka/streams/processor/internals/Task.java    |   6 -
 .../streams/processor/internals/TaskManager.java   |   3 +-
 .../integration/RegexSourceIntegrationTest.java    |   1 -
 .../processor/internals/PartitionGroupTest.java    | 258 +--------------------
 .../processor/internals/StreamTaskTest.java        | 154 ++++++++----
 .../processor/internals/TaskManagerTest.java       |   6 -
 .../internals/testutil/LogCaptureAppender.java     |   4 -
 .../StreamThreadStateStoreProviderTest.java        |   2 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |  24 +-
 24 files changed, 227 insertions(+), 956 deletions(-)
 delete mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchedRecords.java