代码之家  ›  专栏  ›  技术社区  ›  user432024

如何将JDBC驱动程序添加到DC/OS上的Kafka Connect?

  •  0
  • user432024  · 技术社区  · 6 年前

    使用confluent community包在DC/OS上运行Kafka Connect 4.1.1。如何将jdbc驱动程序上载或添加到远程集群?

    更新:这是一个安装了DC/OS目录的包,这是一个mesos框架,运行docker映像。

    1 回复  |  直到 6 年前
        1
  •  3
  •   OneCricketeer Gabriele Mariotti    6 年前

    更新

    借来的剧本 here (thanks to @rmoff)

    CMD 使用bash脚本下载并提取restapi源连接器。

    bash -c 'echo Installing unzip… && \
                    curl -so unzip.deb http://ftp.br.debian.org/debian/pool/main/u/unzip/unzip_6.0-16+deb8u3_amd64.deb && \
                    dpkg -i unzip.deb && \
                    echo Downloading connector… && \
                    curl -so kafka-connect-rest.zip https://storage.googleapis.com/rmoff-connectors/kafka-connect-rest.zip && \
                    mkdir -p /u01/connectors/ && \
                    unzip -j kafka-connect-rest.zip -d /u01/connectors/kafka-connect-rest && \
                    echo Launching Connect… && \
                    /etc/confluent/docker/run'
    

    你需要 build your own Docker images 然后将它们发布到Mesos集群的可解析Docker注册表中,然后编辑Mesos服务以拉取这些图像,而不是合并的图像。

    ADD http://somepath.com/someJDBC-driver.jar /usr/share/java/kafka-connect-jdbc
    

    或者 curl ADD .tar.gz 文件)。

    FROM confluentinc/cp-kafka-connect
    
    ENV MYSQL_DRIVER_VERSION 5.1.39
    
    RUN curl -k -SL "https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-${MYSQL_DRIVER_VERSION}.tar.gz" \
        | tar -xzf - -C /usr/share/java/kafka-connect-jdbc/ --strip-components=1 mysql-connector-java-5.1.39/mysql-connector-java-${MYSQL_DRIVER_VERSION}-bin.jar
    

    你也可以使用 confluent-hub install