I want to set up a MSK connect to listen to a topic where messages are transactionally published. To make the connector transaction-aware, I need to set up consumer.isolation.level
for the workers (or enable client overrides in the worker configuration and then use consumer.override.isolation.level
in the connector config). However, connector.client.config.override.policy
and consumer.isolation.level
are not allowed in MSK worker configuration: https://docs.aws.amazon.com/msk/latest/developerguide/msk-connect-workers.html.
How do I make the MSK sink connector transaction-aware?