[jira] [Commented] (KAFKA-7753) ValueTransformerWithKey should not require producing one value every message

2018-12-20 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725955#comment-16725955 ] Mateusz Owczarek commented on KAFKA-7753: - I see, thanks for quick answer, closing the issue ;)

[jira] [Commented] (KAFKA-7753) ValueTransformerWithKey should not require producing one value every message

2018-12-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725921#comment-16725921 ] Matthias J. Sax commented on KAFKA-7753: If you use punctuations and call `context.forward(key,

[jira] [Commented] (KAFKA-7753) ValueTransformerWithKey should not require producing one value every message

2018-12-20 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725902#comment-16725902 ] Mateusz Owczarek commented on KAFKA-7753: - Actually it would be fine, but because I missread

[jira] [Commented] (KAFKA-7753) ValueTransformerWithKey should not require producing one value every message

2018-12-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16724375#comment-16724375 ] Matthias J. Sax commented on KAFKA-7753: What about returning `null` and apply a filter