Как добавить информацию о теме в метрики шаблона Spring Kafka?JAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Как добавить информацию о теме в метрики шаблона Spring Kafka?

Сообщение Anonymous »

У меня есть метрика «spring_kafka_template_секунд_count», но информации о теме нет. Я использую версию Spring-Kafka 2.8.11. В документе https://docs.spring.io/spring-kafka/ref ... meter.html они говорят, что
Starting with versions 2.9.8, 3.0.6, you can provide a KafkaTemplate.setMicrometerTagsProvider(Function
, Map>) property;
the function receives the ProducerRecord and returns tags which can be based on that record,
and merged with any static tags in micrometerTags.

но я не знаю, как безопасно повысить версию Kafka 2.8.11 -> 2.9.8 (моя версия загрузки Spring — 2.7.18).
Есть ли способ добавить дополнительную информацию в метрики или добавить свои собственные метрики в шаблон Kafka?
Или есть руководство по безопасному увеличению версии Spring-Kafka (или, может быть, список совместимости версий)?
Я попытался создать компонент, реализующий ProducerListener, и переопределить методы onSuccess и onError, но если я добавлю компонент ProducerListener в контекст, LoggingProducerListener не будет создан путем автоконфигурации:
public class KafkaAutoConfiguration {
@Bean
@ConditionalOnMissingBean(ProducerListener.class)
public LoggingProducerListener kafkaProducerListener() {
return new LoggingProducerListener();
}


Подробнее здесь: https://stackoverflow.com/questions/791 ... a-template
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»