@@ -80,10 +80,10 @@ echo -e "\nAdding Redis Kafka Sink Connector for the 'pageviews' topic into the
80
80
curl -X POST -H " Content-Type: application/json" --data '
81
81
{"name": "redis-sink",
82
82
"config": {
83
- "connector.class":"com.redis.kafka.connect.RedisSinkConnector",
84
- "tasks.max":"1",
85
- "topics":"pageviews",
86
- "redis.uri":"redis://redis:6379",
83
+ "connector.class": "com.redis.kafka.connect.RedisSinkConnector",
84
+ "tasks.max": "1",
85
+ "topics": "pageviews",
86
+ "redis.uri": "redis://redis:6379",
87
87
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
88
88
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
89
89
"value.converter.schemas.enable": "false"
@@ -94,28 +94,28 @@ echo -e "\nAdding Redis Kafka Sink Connector for the 'pageviews' topic into Redi
94
94
curl -X POST -H " Content-Type: application/json" --data '
95
95
{"name": "redis-sink-json",
96
96
"config": {
97
- "connector.class":"com.redis.kafka.connect.RedisSinkConnector",
98
- "tasks.max":"1",
99
- "topics":"pageviews",
100
- "redis.uri":"redis://redis:6379",
101
- "redis.command":"JSONSET",
97
+ "connector.class": "com.redis.kafka.connect.RedisSinkConnector",
98
+ "tasks.max": "1",
102
99
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
103
- "value.converter": "org.apache.kafka.connect.storage.StringConverter",
104
- "value.converter.schemas.enable": "false",
100
+ "redis.command": "JSONSET",
101
+ "redis.uri": "redis://redis:6379",
102
+ "topics": "pageviews",
105
103
"transforms": "Cast",
104
+ "transforms.Cast.spec": "string",
106
105
"transforms.Cast.type": "org.apache.kafka.connect.transforms.Cast$Key",
107
- "transforms.Cast.spec": "string"
106
+ "value.converter": "org.apache.kafka.connect.storage.StringConverter",
107
+ "value.converter.schemas.enable": "false"
108
108
}}' http://localhost:8083/connectors -w " \n"
109
109
110
110
sleep 2
111
111
echo -e " \nAdding Redis Kafka Source Connector for the 'mystream' stream:"
112
112
curl -X POST -H " Content-Type: application/json" --data '
113
113
{"name": "redis-source",
114
114
"config": {
115
- "tasks.max":"1",
116
- "connector.class":"com.redis.kafka.connect.RedisStreamSourceConnector",
117
- "redis.uri":"redis://redis:6379",
118
- "redis.stream.name":"mystream",
115
+ "tasks.max": "1",
116
+ "connector.class": "com.redis.kafka.connect.RedisStreamSourceConnector",
117
+ "redis.uri": "redis://redis:6379",
118
+ "redis.stream.name": "mystream",
119
119
"topic": "mystream"
120
120
}}' http://localhost:8083/connectors -w " \n"
121
121
@@ -124,10 +124,10 @@ echo -e "\nAdding Keys Source Connector for keys 'mykey:*':"
124
124
curl -X POST -H " Content-Type: application/json" --data '
125
125
{"name": "redis-keys-source",
126
126
"config": {
127
- "tasks.max":"1",
128
- "connector.class":"com.redis.kafka.connect.RedisKeysSourceConnector",
129
- "redis.uri":"redis://redis:6379",
130
- "redis.keys.pattern":"mykey:*",
127
+ "tasks.max": "1",
128
+ "connector.class": "com.redis.kafka.connect.RedisKeysSourceConnector",
129
+ "redis.uri": "redis://redis:6379",
130
+ "redis.keys.pattern": "mykey:*",
131
131
"topic": "mykeys"
132
132
}}' http://localhost:8083/connectors -w " \n"
133
133
0 commit comments