Limit the number of inflight pulsar mutations

datastax / cdc-apache-cassandra

Datastax CDC for Apache Cassandra

Apache License 2.0

35 stars 21 forks source link

Limit the number of inflight pulsar mutations #118

Closed aymkhalil closed 1 year ago

aymkhalil commented 1 year ago

Limit the number of inflight pulsar mutations to 1000 (hard coded for now) inspired by how the agent doesn't (independent from the blocking send capabilities in the pulsar client)

aymkhalil commented 1 year ago

The latest patch: 1) Implements a fail-fast strategy 2) Rebases on top of master branch to trigger the new CI tests

@eolivelli PTAL