This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 92688ef MINOR: improve the Kafka RPC code generator (#7340)
add 70d1bb4 KAFKA-7273: Extend Connect Converter to support headers
(#6362)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 3 +
.../apache/kafka/connect/storage/Converter.java | 34 +++++
.../kafka/connect/runtime/WorkerSinkTask.java | 4 +-
.../kafka/connect/runtime/WorkerSourceTask.java | 4 +-
.../connect/runtime/TestConverterWithHeaders.java | 80 ++++++++++++
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 138 ++++++++++++++++++++-
.../runtime/WorkerSinkTaskThreadedTest.java | 17 ++-
.../connect/runtime/WorkerSourceTaskTest.java | 128 +++++++++++++++++--
8 files changed, 384 insertions(+), 24 deletions(-)
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TestConverterWithHeaders.java
