kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (e70bc04 -> 448e7d7)
Date Wed, 24 Jun 2020 01:09:11 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from e70bc04  KAFKA-10126:Add a warning message for ConsumerPerformance (#8845)
     add 448e7d7  KAFKA-10169: swallow non-fatal KafkaException and don't abort transaction
during clean close (#8900)

No new revisions were added by this update.

Summary of changes:
 .../streams/errors/TaskMigratedException.java      |   4 +
 .../processor/internals/RecordCollector.java       |   9 +-
 .../processor/internals/RecordCollectorImpl.java   |  38 ++-
 .../streams/processor/internals/StreamTask.java    |  13 +-
 .../streams/processor/internals/StreamThread.java  |   1 -
 .../processor/internals/StreamsMetadataState.java  |  10 +-
 .../streams/processor/internals/TaskManager.java   | 190 +++++++----
 .../integration/RestoreIntegrationTest.java        |   8 +-
 .../processor/internals/RecordCollectorTest.java   | 352 ++++++++++++---------
 .../processor/internals/StreamTaskTest.java        |   2 +-
 .../processor/internals/TaskManagerTest.java       |   6 -
 .../org/apache/kafka/test/MockRecordCollector.java |   5 +-
 12 files changed, 400 insertions(+), 238 deletions(-)


Mime
View raw message