diff --git a/nakadi-producer/src/main/java/org/zalando/nakadiproducer/eventlog/EventLogWriter.java b/nakadi-producer/src/main/java/org/zalando/nakadiproducer/eventlog/EventLogWriter.java
index adbdc5f..244505e 100644
--- a/nakadi-producer/src/main/java/org/zalando/nakadiproducer/eventlog/EventLogWriter.java
+++ b/nakadi-producer/src/main/java/org/zalando/nakadiproducer/eventlog/EventLogWriter.java
@@ -52,15 +52,17 @@ public interface EventLogWriter {
    *            the Nakadi event type of the event. This is roughly equivalent
    *            to an event channel or topic.
    *
-   * @param dataTypeToData
+   * @param dataType
    *            the content of the {@code data_type} field of the Nakadi
-   *            event mapped to some POJOs that can be serialized into JSON (required
+   *            event
+   * @param data
+   *            some POJOs that can be serialized into JSON (required
    *            parameter). This is meant to be a representation of the
    *            current state of the resource. It will be used as content of
    *            the {@code data} field of the Nakadi event.
    */
     @Transactional
-    void fireCreateEvents(String eventType, Map<String, Collection<Object>> dataTypeToData);
+    void fireCreateEvents(String eventType, String dataType, Collection<Object> data);
 
     /**
      * Fires a data change event about an update of some resource (object).