package org.yaourtcorp.kafka.producer.example;

import com.fasterxml.jackson.core.JsonProcessingException;

public interface EventSerializerForKafka<T extends EventObject> {

	String serialize(T eventObject) throws JsonProcessingException;
}

@@ -101,16 +101,143 @@
 ption;%0A%0A
+/*%0A * Interface for serializer for %22event objects%22 (will be called just before sending event to kafka)%0A * @see EventObject%0A */%0A
 public i

Update EventSerializerForKafka.java