This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from a095e1f KAFKA-10847: improve throughput of stream-stream join with
spurious left/outer join fix (#10917)
add 9f01909 KAFKA-12997: Expose the append time for batches from raft
(#10946)
No new revisions were added by this update.
Summary of changes:
.../metadata/BrokerMetadataListenerTest.scala | 3 +-
.../apache/kafka/controller/QuorumController.java | 19 +++--
.../org/apache/kafka/metadata/RecordTestUtils.java | 2 +-
.../org/apache/kafka/metalog/LocalLogManager.java | 40 +++++++----
.../src/main/java/org/apache/kafka/raft/Batch.java | 80 ++++++++++++++++++----
.../org/apache/kafka/raft/KafkaRaftClient.java | 16 +++--
.../org/apache/kafka/raft/ReplicatedCounter.java | 7 +-
.../kafka/raft/internals/BatchAccumulator.java | 27 +++++++-
.../apache/kafka/raft/internals/BatchBuilder.java | 10 +--
.../kafka/raft/internals/RecordsIterator.java | 15 ++--
.../org/apache/kafka/snapshot/SnapshotReader.java | 22 +++++-
.../kafka/raft/internals/BatchAccumulatorTest.java | 4 ++
.../raft/internals/MemoryBatchReaderTest.java | 12 ++--
.../kafka/raft/internals/RecordsIteratorTest.java | 12 ++--
.../org/apache/kafka/shell/SnapshotFileReader.java | 3 +-
15 files changed, 209 insertions(+), 63 deletions(-)
