File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -103,8 +103,10 @@ curl -X POST -H "Content-Type: application/json" --data '
103103 "config": {
104104 "tasks.max":"1",
105105 "connector.class":"com.redislabs.kafka.connect.RedisEnterpriseSourceConnector",
106+ "redis.reader":"STREAM",
106107 "redis.uri":"redis://redis:6379",
107- "redis.stream.name":"mystream"
108+ "redis.stream.name":"mystream",
109+ "topic": "mystream"
108110}}' http://localhost:8083/connectors -w " \n"
109111
110112sleep 2
@@ -126,7 +128,7 @@ echo -e '''
126128Examine the topics in the Kafka UI: http://localhost:9021 or http://localhost:8000/
127129 - The `pageviews` topic should have the generated page views.
128130 - The `mystream` topic should contain the Redis stream messages.
129- - The `pageviews` stream in Redis should contain the sunk page views.
131+ The `pageviews` stream in Redis should contain the sunk page views: redis-cli xlen pageviews
130132
131133Examine the collections:
132134 - In your shell run: docker-compose exec redis /usr/local/bin/redis-cli
You can’t perform that action at this time.
0 commit comments