In our Scala application I am trying to implement custom naming for Kafka Streams application nodes.
We are using topicPattern for our stream source.
Here is an API which I am calling:
Despite the fact that I am providing Consumed with custom name the topology describe still show "KSTREAM-SOURCE-0000000000" as name for our stream source.
It is not a problem if I just use a name for topic. But our application needs to get messages from set of topics based on topicname pattern matching.
After checking the kakfa code I see that
org.apache.kafka.streams.kstream.internals.InternalStreamBuilder (on line 103) has a bug:
node name construction does not take into account the name of consumed parameter.
For example code for another stream api call with topic name does it correctly: