This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 38fee5f MINOR: Time and log producer state recovery phases (#10241)
add a92b986 KAFKA-12268: Implement task idling semantics via currentLag
API (#10137)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 -
checkstyle/suppressions.xml | 5 +-
.../apache/kafka/clients/consumer/Consumer.java | 6 +
.../kafka/clients/consumer/ConsumerRecords.java | 103 +------------
.../kafka/clients/consumer/KafkaConsumer.java | 36 ++++-
.../kafka/clients/consumer/MockConsumer.java | 32 ++--
.../clients/consumer/internals/FetchedRecords.java | 102 -------------
.../kafka/clients/consumer/internals/Fetcher.java | 50 +++----
.../consumer/internals/SubscriptionState.java | 14 +-
.../kafka/clients/consumer/KafkaConsumerTest.java | 163 +++++----------------
.../clients/consumer/internals/FetcherTest.java | 28 ++--
.../kafka/api/PlaintextConsumerTest.scala | 36 ++---
.../processor/internals/PartitionGroup.java | 99 +++++--------
.../streams/processor/internals/StandbyTask.java | 6 -
.../streams/processor/internals/StreamTask.java | 12 +-
.../streams/processor/internals/StreamThread.java | 9 +-
.../kafka/streams/processor/internals/Task.java | 6 -
.../streams/processor/internals/TaskManager.java | 3 +-
.../processor/internals/ActiveTaskCreatorTest.java | 2 +-
.../processor/internals/PartitionGroupTest.java | 29 ++--
.../processor/internals/StreamTaskTest.java | 10 --
.../processor/internals/TaskManagerTest.java | 6 -
.../apache/kafka/streams/TopologyTestDriver.java | 16 --
23 files changed, 203 insertions(+), 571 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchedRecords.java
