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

Push message to specific elastic index based on values of one or more fields of the record #1

Open
rohankapoor1 opened this issue Jul 25, 2019 · 0 comments

Comments

@rohankapoor1
Copy link

I was thinking to propose a new configuration (like record.index.map) while setting up the connector where user can give a record field or combination of record fields which can be used to push this record to a particular ES index.

Eg:
Record = {"fieldA" : "valueA",
"fieldB" : "valueB",
"fieldC" : "valueC",
"fieldD" : "valueD"}

record.index.map = [fieldA]-[fieldC]

So, this record will be stored into ES index named: valueA-valueC
As it will be a default configuration provided so any external Kafka connect plugin like RegexRouter and TimestampRouter may not be needed. And I am thinking this will be useful for many consumers.
What's your thought on this @skynyrd ?
Also, can you please add a license file to the project. It would be nice.

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