Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jdbc Sink Connector - DLQ Partition option is not available #1414

Open
leonardocaylent opened this issue Jul 2, 2024 · 0 comments
Open

Jdbc Sink Connector - DLQ Partition option is not available #1414

leonardocaylent opened this issue Jul 2, 2024 · 0 comments

Comments

@leonardocaylent
Copy link

On the connector configuration we can configure the following:
errors.deadletterqueue.topic.name
errors.deadletterqueue.context.headers.enable
errors.deadletterqueue.topic.replication.factor

But we don't have any option for
errors.deadletterqueue.topic.partitions

It always forces the partition number for DLQs into 1 and this causes errors on AWS MSK Connect.
What are the options to avoid or overwrite this value and make it into 10?

I was trying to see where it does the import for setting that DLQ and I'm not able to find it.

I'm using

            "connector.class" : "io.confluent.connect.jdbc.JdbcSinkConnector",
            "dialect.name" : "PostgreSqlDatabaseDialect",
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant