This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from fdb051e Merge pull request #5119: Removing
PrimitiveCombineGroupedValues override w/ FnAPI
add 062fa48 BEAM-4038: Support Kafka Headers in KafkaIO
add d03e1f4 BEAM-4038: Update license information
add a802315 Merge branch 'master' into kafka-header-support
add c93bcda Update code formatting
add 01f4ebb Remove custom implementations of KafkaHeader, KafkaHeaders,
etc.
add c34faa5 Changes based on review comments
add d249621 Support kafka versions 0.10.1.0 and above
new e6681e8 Merge pull request #5111: [BEAM-4038] Support Kafka Headers
in KafkaIO
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/beam/sdk/io/kafka/ConsumerSpEL.java | 16 +++++++++
.../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 21 ++++++++++--
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 35 +++++++++++++++++++
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 3 +-
.../CustomTimestampPolicyWithLimitedDelayTest.java | 6 ++--
.../beam/sdk/io/kafka/KafkaRecordCoderTest.java | 39 ++++++++++++++++++++++
6 files changed, 114 insertions(+), 6 deletions(-)
--
To stop receiving notification emails like this one, please contact
[email protected].
