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%)
