Former-commit-id: b90485640d1244eb2da0609e57dbd6d4432320a5 Former-commit-id: fc4319d254aee3e6b2ee2e00fe82f684ae412f5a1.0
parent
9abcaf4c6c
commit
a36acf2721
@ -0,0 +1,16 @@
|
|||||||
|
{
|
||||||
|
"name": "inventory-connector",
|
||||||
|
"config": {
|
||||||
|
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
|
||||||
|
"tasks.max": "1",
|
||||||
|
"database.hostname": "mysql",
|
||||||
|
"database.port": "3306",
|
||||||
|
"database.user": "slave",
|
||||||
|
"database.password": "aA123456!",
|
||||||
|
"database.server.id": "1",
|
||||||
|
"database.server.name": "dbserver1",
|
||||||
|
"database.include": "iotcenter",
|
||||||
|
"database.history.kafka.bootstrap.servers": "kafka:9092",
|
||||||
|
"database.history.kafka.topic": "schema-changes.iotcenter"
|
||||||
|
}
|
||||||
|
}
|
@ -1,4 +0,0 @@
|
|||||||
CREATE USER 'slave'@'%' IDENTIFIED BY 'aA123456!';
|
|
||||||
GRANT REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'slave'@'%';
|
|
||||||
|
|
||||||
CREATE DATABASE IF NOT EXISTS jobserver;
|
|
@ -0,0 +1,4 @@
|
|||||||
|
CREATE DATABASE jobserver;
|
||||||
|
CREATE USER 'slave'@'%' IDENTIFIED BY 'aA123456!';
|
||||||
|
GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'slave'@'%';
|
||||||
|
FLUSH PRIVILEGES;
|
@ -0,0 +1,47 @@
|
|||||||
|
version: "3.8"
|
||||||
|
services:
|
||||||
|
zookeeper:
|
||||||
|
image: zookeeper:3.7.0
|
||||||
|
restart: always
|
||||||
|
ports:
|
||||||
|
- 2181:2181
|
||||||
|
kafka:
|
||||||
|
image: wurstmeister/kafka:2.13-2.7.0
|
||||||
|
restart: always
|
||||||
|
environment:
|
||||||
|
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
|
||||||
|
KAFKA_HEAP_OPTS: "-Xmx512m -Xms512m"
|
||||||
|
KAFKA_ADVERTISED_HOST_NAME: 192.168.100.144
|
||||||
|
volumes:
|
||||||
|
- ./data/kafka:/kafka
|
||||||
|
ports:
|
||||||
|
- 9092:9092
|
||||||
|
depends_on:
|
||||||
|
- zookeeper
|
||||||
|
kafka-manager:
|
||||||
|
image: kafkamanager/kafka-manager:3.0.0.4
|
||||||
|
restart: always
|
||||||
|
environment:
|
||||||
|
ZK_HOSTS: zookeeper
|
||||||
|
KAFKA_BROKERS: kafka:9092
|
||||||
|
ports:
|
||||||
|
- 9010:9000
|
||||||
|
depends_on:
|
||||||
|
- zookeeper
|
||||||
|
- kafka
|
||||||
|
# curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://localhost:8083/connectors/ -d @register-mysql.json
|
||||||
|
# https://github.com/debezium/docker-images/blob/master/examples/mysql/1.5/inventory.sql
|
||||||
|
# https://github.com/debezium/debezium-examples/blob/master/tutorial/register-mysql.json
|
||||||
|
connect:
|
||||||
|
image: debezium/connect:1.5
|
||||||
|
environment:
|
||||||
|
- BOOTSTRAP_SERVERS=192.168.100.144:9092
|
||||||
|
- GROUP_ID=1
|
||||||
|
- CONFIG_STORAGE_TOPIC=my_connect_configs
|
||||||
|
- OFFSET_STORAGE_TOPIC=my_connect_offsets
|
||||||
|
- STATUS_STORAGE_TOPIC=my_connect_statuses
|
||||||
|
ports:
|
||||||
|
- 8083:8083
|
||||||
|
depends_on:
|
||||||
|
- mysql
|
||||||
|
- kafka
|
@ -0,0 +1 @@
|
|||||||
|
docker-compose --compatibility -f docker-compose.yml -f docker-compose.override.yml -f docker-compose.lab.yml up --remove-orphans -d
|
Loading…
Reference in new issue