ommunity</a> as well as a new subscription type called <code>Key_Shared</code> subscription type in Pulsar that will allow efficient scaling of the source parallelism. Additional efforts focus around the provision of end-to-end, exactly-once guarantees (currently available only in the source Pulsar connector, and not the sink Pulsar connector) and more efforts around using Pulsar/BookKeeper as a Flink state backend.</p>
<p>You can find a more detailed overview of the integration work between the two communi