You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ni...@apache.org on 2022/09/27 09:17:13 UTC

[pulsar] branch master updated (91f747f119c -> b89c1451551)

This is an automated email from the ASF dual-hosted git repository.

nicoloboschi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from 91f747f119c docs: add developers-landing page to sidebars (#17780)
     add b89c1451551 [improve][pulsar-io-kafka] Add option to copy Kafka headers to Pulsar properties (#17829)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/io/kafka/KafkaAbstractSource.java       | 35 +++++++++++--
 .../apache/pulsar/io/kafka/KafkaBytesSource.java   |  6 ++-
 .../apache/pulsar/io/kafka/KafkaSourceConfig.java  |  6 +++
 .../apache/pulsar/io/kafka/KafkaStringSource.java  |  3 +-
 .../pulsar/io/kafka/KafkaBytesSourceTest.java      | 60 ++++++++++++++++++++++
 .../io/kafka/source/KafkaAbstractSourceTest.java   |  5 +-
 6 files changed, 107 insertions(+), 8 deletions(-)