Skip to content

[hotfix] Supports specifying routing fields #121

New issue

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

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

Already on GitHub? # to your account

Open
wants to merge 1 commit into
base: v3.1
Choose a base branch
from

Conversation

ethan-xiao
Copy link

Supports specifying routing fields during write operations. Parameter name: sink.partition-routing.fields

e.g.
create temporary table order_info_sink (
id BIGINT,
user_id BIGINT,
order_id BIGINT,
PRIMARY KEY (id) NOT ENFORCED
) WITH(
'connector' = 'elasticsearch-7',
'hosts' = 'http://127.0.0.1:9200/',
'index' = 'order_info',
'username' = 'elastic',
'password' = 'mypassword',
'sink.partition-routing.fields' = 'user_id'
);

…Parameter name: sink.partition-routing.fields
# for free to join this conversation on GitHub. Already have an account? # to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant