Skip to content

Commit 83bf138

Browse files
committed
added source connector
1 parent 3d3d5b2 commit 83bf138

20 files changed

+526
-419
lines changed

checkstyle-test-suppressions.xml

Lines changed: 0 additions & 10 deletions
This file was deleted.

checkstyle.xml

Lines changed: 0 additions & 86 deletions
This file was deleted.
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
bootstrap.servers=localhost:9092
2+
key.converter=io.confluent.connect.avro.AvroConverter
3+
key.converter.schema.registry.url=http://localhost:8081
4+
value.converter=io.confluent.connect.avro.AvroConverter
5+
value.converter.schema.registry.url=http://localhost:8081
6+
internal.key.converter=org.apache.kafka.connect.json.JsonConverter
7+
internal.value.converter=org.apache.kafka.connect.json.JsonConverter
8+
internal.key.converter.schemas.enable=false
9+
internal.value.converter.schemas.enable=false
10+
offset.storage.file.filename=/tmp/connect.offsets
11+
rest.port=10001
12+
plugin.path=target/kafka-connect-target/usr/share/kafka-connect

config/sink.properties

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
name=sink
2+
connector.class=com.redislabs.kafkaconnect.RedisEnterpriseSinkConnector
3+
tasks.max=1
4+
topics=test
5+
stream.name.format=test2
6+
redis.uri=redis://localhost:6379

config/source.properties

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
name=source
2-
redis.stream=test
3-
redis.uri=redis://localhost:6379
2+
connector.class=com.redislabs.kafkaconnect.RedisEnterpriseSourceConnector
43
tasks.max=1
5-
connector.class=com.redislabs.kafka.connect.RedisEnterpriseSourceConnector
4+
topic=test
5+
stream=test
6+
redis.uri=redis://localhost:6379

deploy.sh

Lines changed: 0 additions & 5 deletions
This file was deleted.

lombok.config

Lines changed: 0 additions & 2 deletions
This file was deleted.

pom.xml

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,13 @@
5858
<dependency>
5959
<groupId>io.lettuce</groupId>
6060
<artifactId>lettuce-core</artifactId>
61-
<version>6.0.2.RELEASE</version>
61+
<version>6.0.3.RELEASE</version>
62+
<exclusions>
63+
<exclusion>
64+
<groupId>io.netty</groupId>
65+
<artifactId>*</artifactId>
66+
</exclusion>
67+
</exclusions>
6268
</dependency>
6369

6470
<dependency>
@@ -107,6 +113,14 @@
107113

108114
<build>
109115
<plugins>
116+
<plugin>
117+
<groupId>org.apache.maven.plugins</groupId>
118+
<artifactId>maven-checkstyle-plugin</artifactId>
119+
<version>2.17</version>
120+
<configuration>
121+
<skip>true</skip>
122+
</configuration>
123+
</plugin>
110124
<plugin>
111125
<groupId>io.confluent</groupId>
112126
<artifactId>kafka-connect-maven-plugin</artifactId>

src/docs/asciidoc/links.adoc

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
= Links
2+
3+
. https://www.confluent.io/blog/put-several-event-types-kafka-topic/[Should You Put Several Event Types in the Same Kafka Topic?]

src/main/java/com/redislabs/kafka/connect/source/RedisEnterpriseSourceConfig.java

Lines changed: 0 additions & 142 deletions
This file was deleted.

0 commit comments

Comments
 (0)