Great idea! We have similar demands so I have implemented this function in a MySQL source connector, see: https://github.com/Aegeaner/kafka-connector-mysql/blob/master/src/main/java/org/apache/kafka/connect/mysql/EventRecordFactory.java#L347
Thanks, Aegeaner On 6/27/17, 11:45, "Kenji Hayashida" <kenji12...@gmail.com> wrote: Hi all, I have raised a new KIP at https://cwiki.apache.org/confluence/display/KAFKA/KIP+172%3A+Add+regular-expression+topic+support+for+sink+connector The corresponding JIRA is at https://issues.apache.org/jira/browse/KAFKA-3073 I look forward to your feedback. Thanks, Kenji Hayashida