You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by ay...@apache.org on 2023/04/18 21:37:49 UTC

[pulsar] branch master updated (bdb2a96a41a -> 46a65fdc182)

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

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


    from bdb2a96a41a [improve] [broker] Upgrade the BookKeeper dependency to 4.16.1 (#20127)
     add 46a65fdc182 [fix][io] KCA: handle kafka sources that use commitRecord (#20121)

No new revisions were added by this update.

Summary of changes:
 .../io/kafka/connect/KafkaConnectSource.java       | 43 +++++++++++++++++++++-
 ...ceTask.java => ErrRecFileStreamSourceTask.java} |  7 +++-
 ...Test.java => KafkaConnectSourceErrRecTest.java} | 41 ++++-----------------
 3 files changed, 54 insertions(+), 37 deletions(-)
 copy pulsar-io/kafka-connect-adaptor/src/test/java/org/apache/pulsar/io/kafka/connect/{ErrFileStreamSourceTask.java => ErrRecFileStreamSourceTask.java} (77%)
 copy pulsar-io/kafka-connect-adaptor/src/test/java/org/apache/pulsar/io/kafka/connect/{KafkaConnectSourceErrTest.java => KafkaConnectSourceErrRecTest.java} (74%)