Skip to content

Commit 3d3d5b2

Browse files
jruauxjruaux
committed
initial commit
0 parents  commit 3d3d5b2

18 files changed

+897
-0
lines changed

‎.gitignore

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
target/
2+
pom.xml.tag
3+
pom.xml.releaseBackup
4+
pom.xml.versionsBackup
5+
pom.xml.next
6+
release.properties
7+
dependency-reduced-pom.xml
8+
buildNumber.properties
9+
.mvn/timing.properties
10+
redis-enterprise-kafka.iml
11+
12+
# Avoid ignoring Maven wrapper jar file (.jar files are usually ignored)
13+
!/.mvn/wrapper/maven-wrapper.jar
14+
/.classpath
15+
/.project
16+
/.settings/
17+
/.factorypath
18+
/.idea/
19+
/build/
20+
/.gradle/
21+
/bin/
22+
/dump.rdb
23+
.DS_Store

‎Dockerfile

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
FROM confluentinc/cp-kafka-connect-base:0.0.0
2+
3+
COPY target/components/packages/redislabs-redis-enterprise-kafka-1.0.0-SNAPSHOT.zip /tmp/my-connector-0.0.0.zip
4+
5+
RUN confluent-hub install --no-prompt /tmp/my-connector-0.0.0.zip

‎README.md

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
# Redis Enterprise Kafka Connect
2+
3+
Kafka Source and Sink Connectors for Redis Enterprise
4+
5+
## Connectors
6+
### Source
7+
8+
### Sink

‎checkstyle-test-suppressions.xml

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
<?xml version="1.0"?>
2+
3+
<!DOCTYPE suppressions PUBLIC
4+
"-//Checkstyle//DTD SuppressionFilter Configuration 1.2//EN"
5+
"https://checkstyle.org/dtds/suppressions_1_2.dtd">
6+
7+
<!-- Only suppress warnings for tests -->
8+
<suppressions>
9+
<suppress checks="MagicNumber" files=".*[\\/]src[\\/]test[\\/]"/>
10+
</suppressions>

‎checkstyle.xml

Lines changed: 86 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,86 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<!--
3+
4+
Copyright (C) 2017 Jeremy Custenborder ([email protected])
5+
6+
Licensed under the Apache License, Version 2.0 (the "License");
7+
you may not use this file except in compliance with the License.
8+
You may obtain a copy of the License at
9+
10+
http://www.apache.org/licenses/LICENSE-2.0
11+
12+
Unless required by applicable law or agreed to in writing, software
13+
distributed under the License is distributed on an "AS IS" BASIS,
14+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15+
See the License for the specific language governing permissions and
16+
limitations under the License.
17+
18+
-->
19+
<!DOCTYPE module PUBLIC
20+
"-//Puppy Crawl//DTD Check Configuration 1.3//EN"
21+
"http://www.puppycrawl.com/dtds/configuration_1_3.dtd">
22+
<module name="Checker">
23+
<property name="localeLanguage" value="en"/>
24+
25+
<module name="FileTabCharacter"/>
26+
27+
<!-- header -->
28+
<module name="RegexpHeader">
29+
<property name="header" value="/\*\*\nCopyright .*"/>
30+
</module>
31+
32+
<module name="TreeWalker">
33+
34+
<!-- code cleanup -->
35+
<module name="UnusedImports"/>
36+
<module name="RedundantImport"/>
37+
<module name="IllegalImport"/>
38+
<module name="EqualsHashCode"/>
39+
<module name="SimplifyBooleanExpression"/>
40+
<module name="OneStatementPerLine"/>
41+
<module name="SimplifyBooleanReturn"/>
42+
43+
<!-- style -->
44+
<module name="DefaultComesLast"/>
45+
<module name="EmptyStatement"/>
46+
<module name="ArrayTypeStyle"/>
47+
<module name="UpperEll"/>
48+
<module name="LeftCurly"/>
49+
<module name="RightCurly"/>
50+
<module name="EmptyStatement"/>
51+
<module name="ConstantName">
52+
<property name="format" value="(^[A-Z][A-Z0-9]*(_[A-Z0-9]+)*$)|(^log$)"/>
53+
</module>
54+
<module name="LocalVariableName"/>
55+
<module name="LocalFinalVariableName"/>
56+
<module name="MemberName"/>
57+
<module name="ClassTypeParameterName">
58+
<property name="format" value="^[A-Z0-9]*$"/>
59+
</module>
60+
<module name="MethodTypeParameterName">
61+
<property name="format" value="^[A-Z0-9]*$"/>
62+
</module>
63+
<module name="PackageName"/>
64+
<module name="ParameterName"/>
65+
<module name="StaticVariableName"/>
66+
<module name="TypeName"/>
67+
<module name="AvoidStarImport"/>
68+
69+
<!-- whitespace -->
70+
<module name="GenericWhitespace"/>
71+
<module name="NoWhitespaceBefore"/>
72+
<module name="WhitespaceAfter"/>
73+
<module name="NoWhitespaceAfter"/>
74+
<module name="WhitespaceAround">
75+
<property name="allowEmptyConstructors" value="true"/>
76+
<property name="allowEmptyMethods" value="true"/>
77+
</module>
78+
<module name="Indentation">
79+
<property name="basicOffset" value="2"/>
80+
<property name="caseIndent" value="2"/>
81+
</module>
82+
<module name="MethodParamPad"/>
83+
<module name="ParenPad"/>
84+
<module name="TypecastParenPad"/>
85+
</module>
86+
</module>

‎config/connect-avro-docker.properties

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=10000
12+
plugin.path=target/kafka-connect-target/usr/share/kafka-connect

‎config/source.properties

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

‎debug.sh

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
#!/usr/bin/env bash
2+
3+
: ${SUSPEND:='n'}
4+
5+
set -e
6+
7+
mvn clean package
8+
export KAFKA_DEBUG='y'
9+
connect-standalone config/connect-avro-docker.properties config/source.properties

‎deploy.sh

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
mvn clean install
2+
targetdir=/Users/jruaux/dev/confluent-6.1.0/share/java/redis-enterprise-kafka
3+
mkdir -p $targetdir
4+
cp target/redis-enterprise-kafka-1.0.0-SNAPSHOT.jar $targetdir
5+

‎docs/images/logo-redis.svg

Lines changed: 125 additions & 0 deletions
Loading

‎lombok.config

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
config.stopBubbling = true
2+
lombok.addLombokGeneratedAnnotation = true

0 commit comments

Comments
 (0)