You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2020/11/14 21:18:04 UTC
[kafka] branch trunk updated (cb3dc67 -> e14e708)
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 cb3dc67 KAFKA-6687: rewrite topology to allow reading the same topic multiple times in the DSL (#9582)
add e14e708 KAFKA-10684; Avoid additional envelope copies during network transmission (#9563)
No new revisions were added by this update.
Summary of changes:
.../kafka/common/protocol/ByteBufferAccessor.java | 2 +-
.../org/apache/kafka/common/protocol/Message.java | 15 +-
.../common/protocol/MessageSizeAccumulator.java | 60 +++++++
.../common/protocol/ObjectSerializationCache.java | 10 +-
.../org/apache/kafka/common/protocol/Readable.java | 14 +-
.../kafka/common/protocol/RecordsReadable.java | 103 -----------
.../kafka/common/protocol/RecordsWritable.java | 149 ----------------
.../apache/kafka/common/protocol/SendBuilder.java | 194 +++++++++++++++++++++
.../org/apache/kafka/common/protocol/Writable.java | 11 ++
.../kafka/common/requests/AbstractResponse.java | 23 +--
.../kafka/common/requests/EnvelopeRequest.java | 20 ++-
.../kafka/common/requests/EnvelopeResponse.java | 12 ++
.../kafka/common/requests/FetchResponse.java | 41 +----
.../kafka/common/requests/RequestContext.java | 21 ++-
.../kafka/common/requests/RequestHeader.java | 3 +-
.../kafka/common/requests/ResponseHeader.java | 15 ++
.../authenticator/SaslServerAuthenticator.java | 4 +-
.../resources/common/message/EnvelopeRequest.json | 2 +-
.../kafka/common/message/RecordsSerdeTest.java | 27 +--
.../kafka/common/protocol/RecordsWritableTest.java | 63 -------
.../kafka/common/protocol/SendBuilderTest.java | 133 ++++++++++++++
.../kafka/common/record/MultiRecordsSendTest.java | 2 +-
.../common/requests/AbstractResponseTest.java | 53 ------
.../kafka/common/requests/ByteBufferChannel.java | 14 +-
.../ByteBufferChannelTest.java} | 38 ++--
.../kafka/common/requests/EnvelopeRequestTest.java | 31 +++-
.../common/requests/EnvelopeResponseTest.java | 52 ++++++
.../kafka/common/requests/RequestContextTest.java | 29 ++-
.../kafka/common/requests/RequestHeaderTest.java | 15 ++
.../test/java/org/apache/kafka/test/TestUtils.java | 13 ++
.../main/scala/kafka/network/RequestChannel.scala | 10 +-
.../main/scala/kafka/network/SocketServer.scala | 4 +-
.../BrokerToControllerChannelManagerImpl.scala | 1 +
.../scala/kafka/server/ForwardingManager.scala | 2 +-
.../scala/kafka/tools/TestRaftRequestHandler.scala | 2 +-
.../CreateTopicsRequestWithForwardingTest.scala | 6 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 2 +-
.../apache/kafka/message/MessageDataGenerator.java | 149 ++++++++--------
.../org/apache/kafka/message/MessageGenerator.java | 6 +-
39 files changed, 760 insertions(+), 591 deletions(-)
create mode 100644 clients/src/main/java/org/apache/kafka/common/protocol/MessageSizeAccumulator.java
delete mode 100644 clients/src/main/java/org/apache/kafka/common/protocol/RecordsReadable.java
delete mode 100644 clients/src/main/java/org/apache/kafka/common/protocol/RecordsWritable.java
create mode 100644 clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java
delete mode 100644 clients/src/test/java/org/apache/kafka/common/protocol/RecordsWritableTest.java
create mode 100644 clients/src/test/java/org/apache/kafka/common/protocol/SendBuilderTest.java
delete mode 100644 clients/src/test/java/org/apache/kafka/common/requests/AbstractResponseTest.java
copy clients/src/test/java/org/apache/kafka/common/{record/ControlRecordTypeTest.java => requests/ByteBufferChannelTest.java} (52%)
create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/EnvelopeResponseTest.java