defect
Aktuell führt eine leere Message (value = null) auf einem Kafka Topic im Consumer zu einer NullpointerException und blockiert damit die weitere Nachrichtenverarbeitung.
Ursache:
Der ConsumerDispatcher loggt die Verarbeitung jeder Nachricht ('record') und reicht dazu den Inhalt (record.value()) der Nachricht an den KafkaStringLogWriter weiter. In diesem kommt es dann in der Methode writeMetaData() beim Zugriff auf den Wert ('message') der Nachricht zur NullpointerException.
Die Nachricht verbleibt dann auf dem Topic und der Consumer versucht immer wieder sie zu verarbeiten, was immer wieder zum gleichen Problem führt. Die Verarbeitung weiterer Nachrichten ist damit blockiert.