This is an automated email from the ASF dual-hosted git repository.
rxl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from dcaa1d3 fix 2 copies of 3bookie and stop 2 booksie after production.
After the entire bookie is restored, it can be produced at this time, and the
produced data cannot be consumed normally. Restarting the broker can resume
normal (#5965)
add 5c58ff4 [pulsar-flink]Cache Pulsar client to make it shared among
tasks in a process (#5900)
No new revisions were added by this update.
Summary of changes:
.../connectors/pulsar/CachedPulsarClient.java | 106 +++++++++++++++++++++
.../connectors/pulsar/FlinkPulsarProducer.java | 2 +-
.../connectors/pulsar/PulsarConsumerSource.java | 7 +-
.../connectors/pulsar/CachedPulsarClientTest.java | 103 ++++++++++++++++++++
.../pulsar/PulsarConsumerSourceTests.java | 2 +-
5 files changed, 215 insertions(+), 5 deletions(-)
create mode 100644
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java
create mode 100644
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClientTest.java
