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)
