@@ -60,7 +60,7 @@ RUN echo -e 'access.control.allow.methods=GET,POST,PUT,DELETE,OPTIONS\naccess.co
60
60
# ################
61
61
62
62
# Add Stream Reactor and needed components
63
- ARG STREAM_REACTOR_VERSION=1.2.2
63
+ ARG STREAM_REACTOR_VERSION=1.2.3
64
64
ARG KAFKA_VERSION_4SR=2.1.0
65
65
ARG STREAM_REACTOR_URL="https://archive.landoop.com/lkd/packages/connectors/stream-reactor/stream-reactor-${STREAM_REACTOR_VERSION}_connect${KAFKA_VERSION_4SR}.tar.gz"
66
66
ARG ELASTICSEARCH_2X_VERSION=2.4.6
@@ -93,7 +93,7 @@ RUN wget $DEVARCH_USER $DEVARCH_PASS "${STREAM_REACTOR_URL}" -O /stream-reactor.
93
93
done \
94
94
&& rm /calcite-linq4j-${CALCITE_LINQ4J_VERSION}.jar \
95
95
&& mkdir -p /opt/landoop/kafka/share/java/landoop-common \
96
- && for file in $(find /opt/landoop/connectors/stream-reactor -maxdepth 2 -type f -exec basename {} \; | grep -Ev "scala-logging|kafka-connect-common|scala-" | sort | uniq -c | grep -E "^\s +23 " | awk '{print $2}' ); do \
96
+ && for file in $(find /opt/landoop/connectors/stream-reactor -maxdepth 2 -type f -exec basename {} \; | grep -Ev "scala-logging|kafka-connect-common|scala-" | sort | uniq -c | grep -E "^\s +24 " | awk '{print $2}' ); do \
97
97
cp /opt/landoop/connectors/stream-reactor/kafka-connect-elastic/$file /opt/landoop/kafka/share/java/landoop-common/; \
98
98
rm -f /opt/landoop/connectors/stream-reactor/kafka-connect-*/$file; \
99
99
done \
@@ -169,13 +169,13 @@ RUN wget $DEVARCH_USER $DEVARCH_PASS "$KAFKA_CONNECT_COUCHBASE_URL" \
169
169
&& rm -rf /couchbase.zip /couchbase
170
170
171
171
# Kafka Connect Debezium MongoDB / MySQL / Postgres / MsSQL
172
- ARG KAFKA_CONNECT_DEBEZIUM_MONGODB_VERSION=0.9.5 .Final
172
+ ARG KAFKA_CONNECT_DEBEZIUM_MONGODB_VERSION=0.10.0 .Final
173
173
ARG KAFKA_CONNECT_DEBEZIUM_MONGODB_URL="https://search.maven.org/remotecontent?filepath=io/debezium/debezium-connector-mongodb/${KAFKA_CONNECT_DEBEZIUM_MONGODB_VERSION}/debezium-connector-mongodb-${KAFKA_CONNECT_DEBEZIUM_MONGODB_VERSION}-plugin.tar.gz"
174
- ARG KAFKA_CONNECT_DEBEZIUM_MYSQL_VERSION=0.9.5 .Final
174
+ ARG KAFKA_CONNECT_DEBEZIUM_MYSQL_VERSION=0.10.0 .Final
175
175
ARG KAFKA_CONNECT_DEBEZIUM_MYSQL_URL="https://search.maven.org/remotecontent?filepath=io/debezium/debezium-connector-mysql/${KAFKA_CONNECT_DEBEZIUM_MYSQL_VERSION}/debezium-connector-mysql-${KAFKA_CONNECT_DEBEZIUM_MYSQL_VERSION}-plugin.tar.gz"
176
- ARG KAFKA_CONNECT_DEBEZIUM_POSTGRES_VERSION=0.9.5 .Final
176
+ ARG KAFKA_CONNECT_DEBEZIUM_POSTGRES_VERSION=0.10.0 .Final
177
177
ARG KAFKA_CONNECT_DEBEZIUM_POSTGRES_URL="https://search.maven.org/remotecontent?filepath=io/debezium/debezium-connector-postgres/${KAFKA_CONNECT_DEBEZIUM_POSTGRES_VERSION}/debezium-connector-postgres-${KAFKA_CONNECT_DEBEZIUM_POSTGRES_VERSION}-plugin.tar.gz"
178
- ARG KAFKA_CONNECT_DEBEZIUM_SQLSERVER_VERSION=0.9.5 .Final
178
+ ARG KAFKA_CONNECT_DEBEZIUM_SQLSERVER_VERSION=0.10.0 .Final
179
179
ARG KAFKA_CONNECT_DEBEZIUM_SQLSERVER_URL="https://search.maven.org/remotecontent?filepath=io/debezium/debezium-connector-sqlserver/${KAFKA_CONNECT_DEBEZIUM_SQLSERVER_VERSION}/debezium-connector-sqlserver-${KAFKA_CONNECT_DEBEZIUM_SQLSERVER_VERSION}-plugin.tar.gz"
180
180
RUN mkdir -p /opt/landoop/connectors/third-party/kafka-connect-debezium-{mongodb,mysql,postgres,sqlserver} \
181
181
&& wget "$KAFKA_CONNECT_DEBEZIUM_MONGODB_URL" -O /debezium-mongodb.tgz \
0 commit comments