在OpenShift开云体育官方注册网址上部署Debezium

export STRIMZI_VERSION=0.18.0 git clone -b $STRIMZI_VERSION https://github.com/strimzi/strimzi-kafka-operator cd strimzi-kafka-operator #切换到admin用户创建安全对象作为安装的一部分:oc login -u system:admin oc create -f install/cluster-operator && oc create -f examples/templates/cluster-operator

#部署临时单实例Kafka代理:oc process strimzi-ephemeral -p CLUSTER_NAME=broker -p ZOOKEEPER_NODE_COUNT=1 -p KAFKA_NODE_COUNT=1 -p KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 -p KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1 | oc apply -f -

#为数据库配置证书oc set env dc/ MySQL MYSQL_ROOT_PASSWORD=debezium MYS开云体育官方注册网址QL_USER=mysqluser MYSQL_PASSWORD=mysqlpw开云体育电动老虎机

oc get pods NAME READY STATUS重启年龄…mysql-1-4503l 1/1 Running 0 2s mysql-1-deploy 1/1 Running 0 4s…

c . exec -i -c kafka broker-kafka-0——curl - x POST \ - h "Accept:application/json" \ - h "Content-Type:application/json" \ http:开云体育官方注册网址//debezium-connect-api:8083/connectors -d @- <<'EOF' {"name": "inventory-connector"， "config": {"connector.class": "io. debezim .connector.mysql. mysqlconnector "， "任务。Max ": "1"， 开云体育电动老虎机"数据库。主机名:“mysql”，“数据库”。开云体育电动老虎机端口:“3306”，“数据库”。开云体育电动老虎机用户":"deb开云体育官方注册网址ez开云体育电动老虎机ium"， "数据库"。密码":"dbz"， "databas开云体育电动老虎机e.server. "Id ": "184054"， 开云体育电动老虎机"database.server.name": "dbserver1"， "database.include "。List ": "inventory"， 开云体育电动老虎机"database.history.kafka.bootstrap. "Servers ": "broker-kafka-bootstrap:9092"， 开云体育电动老虎机"database.history.kafka. kafka. "主题:“模式变化。库存"}}EOF

Oc logs $(Oc get pods -o name -l strimzi.io/name=开云体育官方注册网址debezium-connect)

Oc exec -it broker-kafka-0——/opt/kafka/bin/kafka-console-consumer.sh \——bootstrap-server localhost:9092 \——from-beginning \——属性打印。Key =true \——topic dbserver1.inventory.customers

#信息1 {"id": 1001} #信息1值{"前":null， "后":{"id": 1001， "first_name": "Sally"， "last_name": "Thomas"， "email": "sally.thomas@acme.com"}， "source": {"version": "1.3.1. "最后”、“连接器”:“mysql”、“名称”:“dbserver1”、“server_id”:0,”ts_sec”:0,”gtid”:空,“文件”:“mysql-bin。000003"， "pos": 154， "row": 0， "snapshot": true， "thread": null， "db": "inventory"， "table": "customers"}， "op": "c"， "ts_ms": 1509530901446} #消息2关键字{"id": 1002} #消息2值{"before": null， "after": {"id": 1002， "first_name": "George"， "last_name": "Bailey"， "email": "gbailey@foobar.com"}， "source": {"version": "1.3.1. "最后”、“连接器”:“mysql”、“名称”:“dbserver1”、“server_id”:0,”ts_sec”:0,”gtid”:空,“文件”:“mysql-bin。000003”、“pos”:154年,“行”:0,“快照”:真的,“线程”:空,“分贝”:“库存”、“表”:“客户”},“人事处”:“c”、“ts_ms”:1509530901446}…

. oc exec -it $(oc get pods -o custom-columns=NAME:.metadata.name——no-headers -l app=mysql) \——bash -c 'mysql -u $MYSQL_USER -p$MYSQL_PASSWORD inventory' #例如执行UPDATE customers SET email="sally.thomas@example.com" WHERE ID = 1001;