Kafka, producer, трейсы и базовые метрики выглядят нормально, но итоговых сообщений/результатов нет. Какие дальнейшие шаги диагностики?

Проследите конкретное событие по ID через все границы: подтверждённую запись producer, нужный topic/cluster, consumer group, обработчик и конечное хранилище. Общие метрики могут скрывать пропажу.

Проверьте offsets, lag, фильтрацию, десериализацию, DLQ, транзакции и момент commit. Убедитесь, что consumers читают нужное окружение и результаты ищут в правильной БД. Сопоставьте время и идентификаторы, не логируя чувствительный payload. После локализации воспроизведите единичный сценарий безопасным тестовым событием, а не массовым повтором production-потока.