#spring-kafka #spring-cloud-sleuth
#spring-kafka #spring-cloud-sleuth
Вопрос:
Когда потребителю не удается обработать запись, SeekToCurrentErrorHandler запускается и выполняет свою работу.
После 10 попыток я вижу строку журнала, в которой указано, что задержка была исчерпана для записи с ошибкой, однако у зарегистрированной записи теперь нет заголовков.
При дальнейшей проверке я вижу, что все повторные попытки записи правильно связаны с общей трассировкой, однако журналы KafkaMessageListenerContainer$ListenerConsumer после каждого сбоя, а затем строка журнала из SeekToCurrentErrorHandler , не отслеживаются.
Как я могу это исправить? Должен ли я передавать пользовательский обработчик ошибок SeekToCurrentErrorHandler в свой собственный регистратор в надежде, что он отслеживает информацию?
В строках журнала отсутствует трассировка:
KafkaMessageListenerContainer$ListenerConsumer [ERROR] Error handler threw an exception
SeekToCurrentErrorHandler [ERROR] Backoff FixedBackOff{...} exhausted for ConsumerRecord(topic=..., ..., headers = RecordHeaders(headers = [], ...), ...)
Я удалил некоторые данные из приведенных выше строк журнала для краткости.
Редактировать: добавление версий
spring-cloud-starter-sleuth: 2.2.4.RELEASE
spring-kafka: 2.5.5.RELEASE
Комментарии:
1. Какую версию Sleuth вы используете? Мы не сможем вам помочь без этой информации. Пожалуйста, убедитесь, что вы используете последнюю версию. Если это так или если вы все еще видите проблемы, вы можете отправить сообщение о проблеме в репозиторий Brave Github, потому что Sleuth просто ссылается на трассировку Brave Kafka.
2. Извините, и каково ожидаемое поведение? Что вы хотели бы видеть в этих журналах?
3. @ArtemBilan ожидаемое поведение заключается в том, что трассировка появляется в этих сообщениях журнала — вместо этого я вижу
[,], что с журналами не было связано трассировки span4. Правильно. Как это должно выглядеть? Дело в том, что я не знаком со всеми этими функциями трассировки, но я могу помочь с исправлением в Spring Kafka. Итак, было бы даже здорово, если бы вы могли поделиться простым проектом для воспроизведения, включая объяснение, чего ожидать в журналах. Вы научите меня трассировкам, а я помогу вам с Spring для Apache Kafka