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

["GeordieMai (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-12337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17286994#comment-17286994 ] 

GeordieMai commented on KAFKA-12337:
------------------------------------

[~ramazanyich]  hello ~
I find in scala KStream
{code:java}
def filter(predicate: (K, V) => Boolean, named: Named)
def selectKey[KR](mapper: (K, V) => KR, named: Named)
def mapValues[VR](mapper: V => VR, named: Named)
...{code}
 

Is it  what you want ?

> 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)