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
    

Reply via email to