Мобильная версияКогда мое приложение обрабатывает сообщения Kafka, я хотел бы иметь одну строку журнала, которая фиксирует необработанное тело сообщения Kafka (в моем случае JSON), а также тему, раздел и смещение для сообщения. Я пробовал реализовать RecordInterceptor, но у него нет доступа к необработанному сообщению до того, как десериализатор его обработает, а десериализатор не имеет доступа к разделу или офсет. Очевидно, что если у меня есть журнал с темой, разделом и смещением, я могу просмотреть исходное сообщение постфактум, но было бы удобнее собрать все четыре вместе в одном месте, где оно будет обрабатываться.
Подробнее здесь: https://stackoverflow.com/questions/791 ... and-offset
