You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hi everyone
How can I copy a message from a topic to another topic with key?
my message in topic A in source has key like "somekey" and when I copy it to sink topic B, the key is empty
this is my connector configuration:
`{
"name": "copy-topic-001",
"config":
{
"schema.ignore": "true",
"value.converter.schemas.enable": "false",
"key.converter.schemas.enable": "false",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
Hi everyone
How can I copy a message from a topic to another topic with key?
my message in topic A in source has key like "somekey" and when I copy it to sink topic B, the key is empty
this is my connector configuration:
`{
"name": "copy-topic-001",
"config":
{
"schema.ignore": "true",
"value.converter.schemas.enable": "false",
"key.converter.schemas.enable": "false",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
}`
and this is my message in source topic:
key: "001"
value:
{ "title": "some title" }
The text was updated successfully, but these errors were encountered: