Spring Kafka重试日志记录

Question

我有一个需求，从一个Kafka主题消费，做一些工作的记录和生产到另一个主题与spring-kafka 2.1.7。其他需求是事务性的，只有一次语义，重试和错误处理。当提交一个记录失败时，我应该做3次重试，记录每个重试消息重试主题。当所有重试失败时，将记录发送到一个死信主题。我查看了https://github.com/spring-projects/spring-kafka/issues/575，它提供了解决问题的非常详细的信息。我正在努力解决的问题是如何记录每个重试消息的细节，如用户偏移，它试图提交的主题，等等。有没有办法从重试回调中获得这些信息？。下面的retrylistener代码段是用org.springframework.kafka.listener.LoggingErrorHandler注册的，它被设置为ConcurrentKafkaListenerContainerFactory的容器属性？

         @Bean
         public RetryListener retryListener(KafkaTemplate<String,SpecificRecord> kafkaTemplate) {
             return new RetryListenerSupport() {

                public void onError(RetryContext context, RetryCallback callback, Throwable throwable) {
                    int retryCount =context.getRetryCount();
                    kafkaTemplate) .send(new ProducerRecord<String,SpecificRecord>("topic_name",record));
                }
             };
         }