Skip to content

Commit 6ac78a1

Browse files
Added schema for source connector
1 parent 5810c5c commit 6ac78a1

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

src/docs/asciidoc/source.adoc

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,22 @@ Use configuration property `tasks.max` to have the change stream handled by mult
4747
=== Stream Reader
4848
The {name} reads messages from a stream and publishes to a Kafka topic. Reading is done through a consumer group so that <<multiple-tasks,multiple instances>> of the connector configured via the `tasks.max` can consume messages in a round-robin fashion.
4949
50+
51+
==== Schema
52+
53+
The schema for the records produced by the source connector is the following:
54+
55+
[source,json]
56+
----
57+
{
58+
"type": "map",
59+
"values": "string",
60+
"connect.name": "com.redislabs.kafka.connect.StreamEventValue"
61+
}
62+
----
63+
64+
==== Configuration
65+
5066
[source,properties]
5167
----
5268
redis.stream.name=<name> <1>

0 commit comments

Comments
 (0)