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 2023/11/20 18:40:57 UTC

(kafka) branch trunk updated (4eb8ae68ca1 -> e905ef1edfb)

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 4eb8ae68ca1 KAFKA-15836: KafkaConsumer subscribes to multiple topics does not respect max.poll.records (#14789)
     add e905ef1edfb MINOR: Small LogValidator clean ups (#14697)

No new revisions were added by this update.

Summary of changes:
 .../kafka/common/record/ConvertedRecords.java      | 10 +--
 .../apache/kafka/common/record/FileRecords.java    |  2 +-
 .../record/LazyDownConversionRecordsSend.java      | 10 +--
 .../kafka/common/record/MultiRecordsSend.java      |  4 +-
 ...ersionStats.java => RecordValidationStats.java} | 17 +++--
 .../apache/kafka/common/record/RecordsUtil.java    |  2 +-
 .../common/record/MemoryRecordsBuilderTest.java    |  2 +-
 core/src/main/scala/kafka/log/UnifiedLog.scala     |  4 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  6 +-
 .../main/scala/kafka/server/ReplicaManager.scala   | 12 ++--
 .../AbstractCoordinatorConcurrencyTest.scala       |  4 +-
 .../scala/unit/kafka/log/LogValidatorTest.scala    | 64 +++++++++++-------
 .../unit/kafka/server/MockFetcherThread.scala      |  2 +-
 .../kafka/server/ReplicaFetcherThreadTest.scala    |  6 +-
 .../kafka/storage/internals/log/LogAppendInfo.java | 34 +++++-----
 .../kafka/storage/internals/log/LogValidator.java  | 77 +++++++++++-----------
 16 files changed, 140 insertions(+), 116 deletions(-)
 rename clients/src/main/java/org/apache/kafka/common/record/{RecordConversionStats.java => RecordValidationStats.java} (78%)