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

Configuration for destination table name #50

Closed
clamoris opened this issue Feb 1, 2023 · 3 comments
Closed

Configuration for destination table name #50

clamoris opened this issue Feb 1, 2023 · 3 comments
Labels
enhancement New feature or request

Comments

@clamoris
Copy link

clamoris commented Feb 1, 2023

It would useful to have an ability to configure destination table name in connector, instead of relying on a topic name in Kafka.

@Paultagoras
Copy link
Contributor

So the current recommendation (via Kafka Connect) is to use SMT to alter the topic name being presented to the connector. This allows for custom names, while keeping the original topic unaltered - if folks would like to discuss this approach vs others, please reach out!

@orginux
Copy link

orginux commented Jan 23, 2024

Could you give an example of altering a topic name?

@IvanKlunney
Copy link

Could you give an example of altering a topic name?

You can use task topic2TableMap setting.

{
    "connector.class":"com.clickhouse.kafka.connect.ClickHouseSinkConnector",
    ...
    "topic2TableMap":"foo=bar"
}

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

5 participants