fixes #282: Documentation mistakes on Sink and FAQ section (#283)

Author: mroiter-larus

doc/asciidoc/consumer/configuration.adoc

@@ -17,7 +17,7 @@ kafka.value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserial
 {environment}.topic.cud=<LIST_OF_TOPICS_SEPARATED_BY_SEMICOLON>
 {environment}.topic.pattern.node.<TOPIC_NAME>=<NODE_EXTRACTION_PATTERN>
 {environment}.topic.pattern.relationship.<TOPIC_NAME>=<RELATIONSHIP_EXTRACTION_PATTERN>
-{environment}.enabled=<true/false, default=true>
+{environment}.enabled=<true/false, default=false>
 ----
 
 See the https://kafka.apache.org/documentation/#brokerconfigs[Apache Kafka documentation] for details on these settings.

doc/asciidoc/docker/data/docker-compose-source-sink.yml

@@ -45,7 +45,7 @@ services:
       NEO4J_dbms_logs_debug_level: DEBUG
       NEO4J_streams_sink_enabled: "true"
       NEO4J_streams_sink_topic_neo4j:
-        "WITH event.value.payload AS payload, event.value.meta AS meta
+        "WITH event.payload AS payload, event.value.meta AS meta
         FOREACH (ignoreMe IN CASE WHEN payload.type = 'node' AND meta.operation <> 'deleted' and payload.after.labels[0] = 'Question' THEN [1] ELSE [] END |
           MERGE (n:Question{neo_id: toInteger(payload.id)}) ON CREATE
             SET n += payload.after.properties

doc/asciidoc/docker/index.adoc

@@ -74,6 +74,7 @@ From the same directory where the compose file is, you can launch this command:
 docker-compose up -d
 ----
 
+[#streams_docker_source_module]
 ==== Source module
 
 Following a compose file that allows you to spin-up Neo4j, Kafka and Zookeeper in order to test the application.
@@ -147,7 +148,7 @@ one configured as `Source` and one as `Sink`, allowing you to share any data fro
     environment:
       NEO4J_streams_sink_enabled: "true"
       NEO4J_streams_sink_topic_neo4j:
-        "WITH event.value.payload AS payload, event.value.meta AS meta
+        "WITH event.payload AS payload, event.value.meta AS meta
         FOREACH (ignoreMe IN CASE WHEN payload.type = 'node' AND meta.operation <> 'deleted' and payload.after.labels[0] = 'Question' THEN [1] ELSE [] END |
           MERGE (n:Question{neo_id: toInteger(payload.id)}) ON CREATE
             SET n += payload.after.properties

doc/asciidoc/faq/index.adoc

@@ -85,8 +85,9 @@ Other references to how to configure it to connect to the Confluent Cloud can be
 
 === Kafka output events description
 
-If you configure the Neo4j Streams plugin as Sink, using a Cypher query in order to ingest data from Kafka into Neo4j,
-watching the Kafka console consumer output you will see JSON events which describes nodes and relationships creation.
+If you configure the Neo4j Streams plugin as Source, using a Cypher query in order to send data from Neo4j to Kafka
+(i.e. see <<streams_docker_source_module, Source module>> section for more details), watching the Kafka console consumer
+output you will see JSON events, which describes nodes and relationships creation.
 They looks like as following:
 
 [source, json]