NATS sink in Debezium Server currently relies on synchronous publishing, it limits performance for high volume stream scenarios (e.g. snapshots) Enhance the Debezium Server NATS JetStream sink to support asynchronous message publishing using NATS JetStream's publishAsync method. This will allow Debezium server to send CDC change events to NATS stream with improved throughput.

This enhancement is motivated by a throughput issue discussed with ccranfor@redhat.com

The implementation takes reference from existing publish usage, NATS JetStream documents and java client examples at: https://github.com/nats-io/nats.java/blob/main/src/examples/java/io/nats/examples/jetstream/NatsJsPubAsync2.java

Which use case/requirement will be addressed by the proposed feature?

Asynchronously publishing to NATS JetStream