value // Value
);
- record.headers().add("source", id.getBytes());
- if (correlationId != null)
- {
- record.headers().add("id", BigInteger.valueOf(correlationId).toByteArray());
- }
+ // TODO: Fügen Sie die Header zu der Nachricht hinzu
producer.send(record, (metadata, e) ->
{