title: Neo4j Sink not recieving Kafka Topic events
body: <p>I have used docker compose to set up an instance of Neo4j with the streams plug in and the apoc procedures. Code is below:</p>
  
  <pre><code>neo4j-sink:
      image: neo4j:3.5
      hostname: neo4j-sink
      container_name: neo4j-sink
  #    depends_on:
  #      - neo4j-source
      ports:
        - "7474:7474"
        - "7687:7687"
      volumes:
         - ./neo4j/plugins:/plugins
      environment:
        NEO4J_kafka_zookeeper_connect: 0.0.0.0:2181
        NEO4J_kafka_bootstrap_servers: 0.0.0.0:9092
  #      NEO4J_AUTH: neo4j/sink
        NEO4J_dbms_memory_heap_max_size: 2G
        NEO4J_kafka_max_poll_records: 10000
        NEO4J_dbms_logs_debug_level: DEBUG
        NEO4J_streams_sink_enabled: "true"
        NEO4J_kafka_group_id: "neo4j_sink_1"
        NEO4J_enable_auto_commit: "true"
        NEO4J_streams_sink_topic_cypher_ARTICLECOMMIT: "WITH event.value as payload MERGE (a:Article {id: payload.ID}) ON CREATE set a.descr = payload.og_description"
  </code></pre>
  
  <p>This has led to the sink initialising and listening to the topic:</p>
  
  <pre><code>neo4j-sink    | 2019-09-14 09:45:54.962+0000 INFO  Starting the Kafka Sink
  neo4j-sink    | 2019-09-14 09:45:55.473+0000 INFO  Creating Sink daemon Job
  neo4j-sink    | 2019-09-14 09:45:55.478+0000 DEBUG Subscribed topics with Cypher queries: {ARTICLECOMMIT=WITH event.value as payload MERGE (a:Article {id: payload.ID}) ON CREATE set a.descr = payload.og_description}
  neo4j-sink    | 2019-09-14 09:45:55.479+0000 DEBUG Subscribed topics with CDC configuration: {CDC_SOURCE_ID=[], CDC_SCHEMA=[]}
  neo4j-sink    | 2019-09-14 09:45:55.480+0000 INFO  Kafka Sink started
  neo4j-sink    | 2019-09-14 09:45:55.480+0000 INFO  Streams Sink module initialised
  </code></pre>
  
  <p>however from the command line producer OR when I send a message through my stream, it does not register in neo4J. I can confirm that the topic is recieving messages from my streams; I checked through the Kafka-console-consumer and listening in the stream. Please advise if there is anything I am doing wrong.</p>
  
  <p>I tried this: </p>
  
  <pre><code>$ kafka-console-producer --broker-list 0.0.0.0:9092 --topic ARTICLECOMMIT
  &gt;{"ID":12345,"og_descrpition":"12312312"}
  </code></pre>
  
  <p>which is the most basic attempt thatpublishes to the topic. but no event received to neo4j. Can someone help </p>