You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Ramil Israfilov (Jira)" <ji...@apache.org> on 2021/02/18 13:48:00 UTC

[jira] [Created] (KAFKA-12337) provide full scala api for operators naming

Ramil Israfilov created KAFKA-12337:
---------------------------------------

             Summary: 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


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)