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

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


    from 58e1dff  Function: add possibility to pass additional JVM arguments to 
the function JVM (additionalJavaRuntimeArguments) (#13282)
     add 1456f87  Allow to config Sasl configs in Kafka source (#13095)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/io/kafka/KafkaAbstractSource.java       | 25 +++++++++++++
 .../apache/pulsar/io/kafka/KafkaSinkConfig.java    |  4 +-
 .../apache/pulsar/io/kafka/KafkaSourceConfig.java  | 43 ++++++++++++++++++++++
 .../io/kafka/source/KafkaAbstractSourceTest.java   | 19 +++++++++-
 ...kConfigSasl.yaml => kafkaSourceConfigSasl.yaml} |  5 ++-
 5 files changed, 91 insertions(+), 5 deletions(-)
 copy pulsar-io/kafka/src/test/resources/{kafkaSinkConfigSasl.yaml => 
kafkaSourceConfigSasl.yaml} (94%)

Reply via email to