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 81465a1 MINOR: Add KIP-584 to upgrade.html file (#9511)
add 927edfe KAFKA-10601; Add support for append linger to Raft
implementation (#9418)
No new revisions were added by this update.
Summary of changes:
.../kafka/common/protocol/ByteBufferAccessor.java | 21 ++
.../common/protocol/DataOutputStreamWritable.java | 146 +++++++++
.../org/apache/kafka/common/protocol/Readable.java | 2 +
.../kafka/common/protocol/RecordsReadable.java | 11 +
.../kafka/common/protocol/RecordsWritable.java | 10 +
.../org/apache/kafka/common/protocol/Writable.java | 2 +
.../apache/kafka/common/record/DefaultRecord.java | 11 +-
.../kafka/common/record/DefaultRecordBatch.java | 32 +-
.../kafka/common/RecordValidationException.scala | 3 +-
.../scala/kafka/raft/KafkaNetworkChannel.scala | 28 +-
.../scala/kafka/tools/TestRaftRequestHandler.scala | 80 +----
.../main/scala/kafka/tools/TestRaftServer.scala | 278 +++++++++++++----
.../unit/kafka/raft/KafkaNetworkChannelTest.scala | 12 +-
raft/README.md | 25 +-
raft/bin/test-raft-server-start.sh | 5 -
.../org/apache/kafka/raft/KafkaRaftClient.java | 312 +++++++++----------
.../java/org/apache/kafka/raft/RaftClient.java | 50 ++-
.../java/org/apache/kafka/raft/RaftConfig.java | 16 +-
.../java/org/apache/kafka/raft/RecordSerde.java | 52 ++++
.../org/apache/kafka/raft/ReplicatedCounter.java | 102 ++----
.../kafka/raft/internals/BatchAccumulator.java | 346 +++++++++++++++++++++
.../apache/kafka/raft/internals/BatchBuilder.java | 306 ++++++++++++++++++
.../kafka/raft/internals/BatchMemoryPool.java | 107 +++++++
.../apache/kafka/raft/internals/StringSerde.java | 29 +-
.../org/apache/kafka/raft/KafkaRaftClientTest.java | 327 ++++++++-----------
.../test/java/org/apache/kafka/raft/MockLog.java | 38 ++-
.../java/org/apache/kafka/raft/MockLogTest.java | 3 +-
.../apache/kafka/raft/RaftClientTestContext.java | 169 +++++++---
.../apache/kafka/raft/RaftEventSimulationTest.java | 52 +++-
.../kafka/raft/internals/BatchAccumulatorTest.java | 296 ++++++++++++++++++
.../kafka/raft/internals/BatchBuilderTest.java | 129 ++++++++
.../kafka/raft/internals/BatchMemoryPoolTest.java | 107 +++++++
.../apache/kafka/tools/ProducerPerformance.java | 6 +-
33 files changed, 2389 insertions(+), 724 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/common/protocol/DataOutputStreamWritable.java
create mode 100644 raft/src/main/java/org/apache/kafka/raft/RecordSerde.java
create mode 100644
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
create mode 100644
raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java
create mode 100644
raft/src/main/java/org/apache/kafka/raft/internals/BatchMemoryPool.java
copy
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenMock.java
=> raft/src/main/java/org/apache/kafka/raft/internals/StringSerde.java (62%)
create mode 100644
raft/src/test/java/org/apache/kafka/raft/internals/BatchAccumulatorTest.java
create mode 100644
raft/src/test/java/org/apache/kafka/raft/internals/BatchBuilderTest.java
create mode 100644
raft/src/test/java/org/apache/kafka/raft/internals/BatchMemoryPoolTest.java
