[ https://issues.apache.org/jira/browse/KAFKA-12337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287017#comment-17287017 ]
Ramil Israfilov commented on KAFKA-12337: ----------------------------------------- ok, looks like it is done as part of KAFKA-8744 which is marked resolved for upcoming 2.8.0 version. So waiting for 2.8.0 release then. Thanks. You can close it as 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)