kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (c3177a1 -> f41a5c2)
Date Thu, 10 Oct 2019 21:45:16 GMT
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 c3177a1  Add wait condition for state RUNNING (#7476)
     add f41a5c2  KAFKA-8729, pt 3: Add broker-side logic to handle the case when there are
record_errors and error_message (#7167)

No new revisions were added by this update.

Summary of changes:
 .../kafka/common/requests/ProduceRequest.java      |  2 +-
 .../kafka/common/requests/ProduceResponse.java     | 99 ++++++++++++++--------
 .../resources/common/message/ProduceRequest.json   |  2 +-
 .../resources/common/message/ProduceResponse.json  | 12 +--
 .../apache/kafka/common/message/MessageTest.java   | 14 +--
 .../kafka/common/requests/RequestResponseTest.java |  3 +-
 ...ption.scala => RecordValidationException.scala} |  9 +-
 core/src/main/scala/kafka/log/Log.scala            | 18 +++-
 core/src/main/scala/kafka/log/LogValidator.scala   | 69 ++++++++++-----
 .../main/scala/kafka/server/ReplicaManager.scala   | 37 +++++---
 core/src/test/scala/unit/kafka/log/LogTest.scala   | 10 +--
 .../scala/unit/kafka/log/LogValidatorTest.scala    | 58 +++++++++++--
 .../unit/kafka/server/ProduceRequestTest.scala     | 36 +++++++-
 13 files changed, 265 insertions(+), 104 deletions(-)
 copy core/src/main/scala/kafka/common/{LogCleaningAbortedException.scala => RecordValidationException.scala}
(74%)


Mime
View raw message