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 (16ee326 -> d8756e8)
Date Sat, 15 Feb 2020 01:29:00 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 16ee326  KAFKA-9556; Fix two issues with KIP-558 and expand testing coverage (#8085)
     add d8756e8  KAFKA-9274: Gracefully handle timeout exception (#8060)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/producer/KafkaProducerTest.java  | 14 ++++-
 .../processor/internals/RecordCollector.java       |  7 +++
 .../processor/internals/RecordCollectorImpl.java   | 33 ++++++++---
 .../streams/processor/internals/StreamTask.java    | 13 +++++
 .../streams/processor/internals/TaskManager.java   | 11 +++-
 .../processor/internals/RecordCollectorTest.java   | 65 ++++++++++++----------
 .../processor/internals/StreamThreadTest.java      |  4 --
 .../org/apache/kafka/test/MockRecordCollector.java |  3 +
 8 files changed, 104 insertions(+), 46 deletions(-)


Mime
View raw message