Tutorial by Topics: deserializer

Kafka stores and transports byte arrays in its queue. The (de)serializers are responsible for translating between the byte array provided by Kafka and POJOs. public void configure(Map<String, ?> config, boolean isKey); public T deserialize(String topic, byte[] bytes); public byte[] ser...

Page 1 of 1