+ ProducerRecord<String, Bytes> toRecord(int partition, String key, Bytes value, String type)
+ {
+ ProducerRecord<String, Bytes> record =
+ new ProducerRecord<>(TOPIC, partition, key, value);
+ record.headers().add("__TypeId__", type.getBytes());
+ return record;
+ }
+
+ Bytes serializeClientMessage(String key, Long value)