This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 18e6bb2 KAFKA-8861 Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic (#7281) add 8d8e2fb KAFKA-8729, pt 1: Add 4 new metrics to keep track of various types of invalid record rejections (#7142) No new revisions were added by this update. Summary of changes: core/src/main/scala/kafka/log/Log.scala | 9 +- core/src/main/scala/kafka/log/LogValidator.scala | 119 ++++++++----- .../scala/kafka/server/KafkaRequestHandler.scala | 21 ++- core/src/test/scala/unit/kafka/log/LogTest.scala | 12 +- .../scala/unit/kafka/log/LogValidatorTest.scala | 197 +++++++++++++++++---- .../scala/unit/kafka/metrics/MetricsTest.scala | 32 ++-- .../unit/kafka/server/ProduceRequestTest.scala | 5 + .../test/scala/unit/kafka/utils/TestUtils.scala | 11 ++ 8 files changed, 300 insertions(+), 106 deletions(-)