How to get consumer information in RetryTopicNamesProviderFactory

[deanpullenesure]

Similar to this question which was unanswered #3339 I'm trying to get groupId or consumer specific properties to be usable within RetryTopicNamesProviderFactory so that I can create specific retry/error topic names.

I kicked off a question on stack overflow (https://stackoverflow.com/questions/79710945/how-to-customise-retrytopicnamesprovider-with-groupid-or-similar-properties) too with the following text:

The difficulty (for me!) is the current implementation of getTopicName(String topic) in RetryTopicNamesProvider. This only accepts a topic name, whilst all the other methods have a method signature of "KafkaListenerEndpoint endpoint".

If this was available I could do something like the below to specify error/retry topics explicitly from config:

@KafkaListener(topics = "#{config.![value.getIngressTopic()]}",
    properties = {
      "retryTopic:#{config.![value.getRetryTopic()]}",
      "errorTopic:#{config.![value.getErrorTopic()]}"
    }
    

and use something like this in the RetryTopicNamesProvider:

endpoint.getConsumerProperties()).getProperty("retryTopic")

Or the groupId.

Unforunately 'endpoint' isn't present in getTopicName which is the ultimate decider of the retry/error topic name.

Gary Russell in this thread How work RetryTopic with other groupId and backOff properties suggesting customising it to allow groupId - but looking at the Spring code I simply can't make heads or tails on how to go about it. I

Any help or pointers are appreciated.

[artembilan]

Will it help if we add a new String getTopicName(String topic, KafkaListenerEndpoint endpoint); API and used it instead at the proper library place?

[deanpullenesure]

Yes that would be awesome if you think that's a good solution....!

[artembilan]

Yeah... Just speculating.
I don't know that part of the library well, therefore cannot judge what is going on.