You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2020/04/09 20:12:10 UTC
[kafka] branch trunk updated (73ec730 -> bf6dffe)
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