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...