zoukankan      html  css  js  c++  java
  • kafka conet

    指令:
    export JAVA_HOME=/usr/java/jdk1.8.0_172-amd64
    export PATH=(JAVA_HOME/bin:)PATH
    export CLASSPATH=.:(JAVA_HOME/lib/*:)JAVA_HOME/jre/lib/:/opt/java/lib/

    bin/kafka-server-start.sh config/server.properties
    /opt/kafka/bin/connect-standalone.sh /kafka/config/connect-standalone.properties /kafka/config/source-pg.properties

    配置:
    name=test-source-postgres-jdbc
    connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
    tasks.max=1
    connection.url=jdbc:postgresql://192.168.1.16/test?user=postgres&password=postgres
    mode=incrementing
    incrementing.column.name=id
    topic.prefix=test-kafka-
    table.whitelist=test

  • 相关阅读:
    maven
    ELK
    gitlab 升级
    平安工作流程
    平安云应用场景
    nginx基于uwsgi部署Django (单机搭建)
    ansible
    nginx理论
    GIT
    docker(三)
  • 原文地址:https://www.cnblogs.com/javaite/p/8930825.html
Copyright © 2011-2022 走看看