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 73ec730 KAFKA-9748: Extend Streams integration tests for EOS beta
(#8441)
add bf6dffe KAFKA-9309: Add the ability to translate Message classes to
and from JSON (#7844)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 5 +
.../org/apache/kafka/common/protocol/Message.java | 48 ++-
.../apache/kafka/common/protocol/MessageUtil.java | 103 ++++++
.../apache/kafka/common/message/MessageTest.java | 11 +
.../java/org/apache/kafka/message/FieldSpec.java | 5 +
.../java/org/apache/kafka/message/FieldType.java | 12 +
.../apache/kafka/message/IsNullConditional.java | 47 ++-
.../apache/kafka/message/MessageDataGenerator.java | 398 +++++++++++++++++++--
.../org/apache/kafka/message/MessageGenerator.java | 24 ++
.../main/java/org/apache/kafka/message/Target.java | 93 +++++
.../kafka/message/IsNullConditionalTest.java | 8 +-
11 files changed, 699 insertions(+), 55 deletions(-)
create mode 100644 generator/src/main/java/org/apache/kafka/message/Target.java
