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
