File tree Expand file tree Collapse file tree 3 files changed +14
-5
lines changed Expand file tree Collapse file tree 3 files changed +14
-5
lines changed Original file line number Diff line number Diff line change 1+ [[docker]]
12== Execute with Docker
23
34Following you'll find a lightweight Docker Compose file that allows you to test the application in your local environment
@@ -64,7 +65,8 @@ And if you go back to your consumer you'll see something like this:
6465
6566In case of you are using the Sink you can define your topic/cypher-query combination as it follows:
6667
67- ```yml
68+ [source,yaml]
69+ ----
6870 environment:
6971 NEO4J_streams_sink_topic_neo4j:
7072 "WITH event.value.payload AS payload, event.value.meta AS meta
@@ -104,9 +106,10 @@ In case of you are using the Sink you can define your topic/cypher-query combina
104106 MERGE (e:Question{neo_id: toInteger(payload.end.id)})
105107 CREATE (s)-[:ASKED{neo_id: toInteger(payload.id)}]->(e)
106108 )"
107- ``
109+ ----
108110
109111.docker-compose.yml
110- ```yml
112+ [source,yaml]
113+ ----
111114include::data/docker-compose.yml[]
112- ```
115+ ----
Original file line number Diff line number Diff line change @@ -51,4 +51,6 @@ include::producer/index.adoc[]
5151
5252include::consumer/index.adoc[]
5353
54- include::procedures/index.adoc[]
54+ include::procedures/index.adoc[]
55+
56+ include::docker/index.adoc[]
Original file line number Diff line number Diff line change @@ -23,6 +23,10 @@ The message retrieved from the Consumer is the following:
2323
2424`{"payload":"Hello world from Neo4j!"}`
2525
26+ If you use a local <<docker,docker (compose) setup>>, you can check for these messages with:
27+
28+ `docker exec -it kafka kafka-console-consumer --topic my-topic --bootstrap-server kafka:9092`
29+
2630Input Parameters:
2731
2832[cols="3*",options="header"]
You can’t perform that action at this time.
0 commit comments