value // Value
);
- record.headers().add("source", id.getBytes());
- if (correlationId != null)
- {
- record.headers().add("id", BigInteger.valueOf(correlationId).toByteArray());
- }
-
producer.send(record, (metadata, e) ->
{
long now = System.currentTimeMillis();