You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2017/09/11 21:02:00 UTC
[jira] [Created] (KAFKA-5869) SMT to select Kafka topic based on
field in message key or value
Yeva Byzek created KAFKA-5869:
---------------------------------
Summary: SMT to select Kafka topic based on field in message key or value
Key: KAFKA-5869
URL: https://issues.apache.org/jira/browse/KAFKA-5869
Project: Kafka
Issue Type: New Feature
Components: KafkaConnect
Reporter: Yeva Byzek
For a given source connector, it would be useful to be able to dynamically determine the Kafka topic to write to based on a field in the message key or value.
The topic name can be:
(a) derived from the field, e.g.
{noformat}
"topic-${field}"
{noformat}
or
(b) branch on the field, e.g.
{noformat}
"topic1" if ${field}=x
"topic2" if ${field}=y
{noformat}
Workaround: create a custom SMT, that generates a new record to the desired topic
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)