You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "GeordieMai (Jira)" <ji...@apache.org> on 2021/02/21 17:09:00 UTC
[jira] [Resolved] (KAFKA-12337) provide full scala api for
operators naming
[ https://issues.apache.org/jira/browse/KAFKA-12337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
GeordieMai resolved KAFKA-12337.
--------------------------------
Resolution: Duplicate
> provide full scala api for operators naming
> --------------------------------------------
>
> Key: KAFKA-12337
> URL: https://issues.apache.org/jira/browse/KAFKA-12337
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 2.7.0
> Reporter: Ramil Israfilov
> Priority: Major
>
> Kafka Streams Java DSL provides possibility to do custom naming for all operators via Named, Grouped, Consumed objects (there is a separate dev guide page about it [https://kafka.apache.org/27/documentation/streams/developer-guide/dsl-topology-naming.html] )
> But Scala api for Kafka Streams provide only partial support.
> For example following API's are missing custom naming:
> filter,selectKey, map, mapValues, flatMap...
> Probably there is same issue for other scala objects.
> As workaround I have to do quite ugly calls to inner KStream java class and perform scala2java and back conversions.
> Would be really handy if all custom naming API's will be also supported on Scala Kafka Streams DSL
--
This message was sent by Atlassian Jira
(v8.3.4#803005)