kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (fc0963a -> 0971f66)
Date Wed, 23 Oct 2019 15:45:39 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from fc0963a  KAFKA-9078: Fix Connect system test after adding MM2 connector classes
     add 0971f66  KAFKA-9056; Inbound/outbound byte metrics should reflect incomplete sends/receives
(#7551)

No new revisions were added by this update.

Summary of changes:
 .../kafka/common/network/ByteBufferSend.java       |   4 +
 .../apache/kafka/common/network/KafkaChannel.java  |  65 ++++----
 .../kafka/common/network/NetworkReceive.java       |  13 +-
 .../org/apache/kafka/common/network/Selector.java  | 166 ++++++++++++++-------
 .../kafka/common/network/KafkaChannelTest.java     | 107 +++++++++++++
 .../kafka/common/network/NetworkReceiveTest.java   |  72 +++++++++
 .../apache/kafka/common/network/SelectorTest.java  |  55 ++++++-
 .../java/org/apache/kafka/test/TestCondition.java  |   2 +-
 .../unit/kafka/network/SocketServerTest.scala      |   8 +-
 9 files changed, 393 insertions(+), 99 deletions(-)
 create mode 100644 clients/src/test/java/org/apache/kafka/common/network/KafkaChannelTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/common/network/NetworkReceiveTest.java


Mime
View raw message