Kafka-Connect 接入 Kafka

配置

schema-registry即可以配置zookeeper的地址, 也可以配置 kafka-broker 的地址。建议使用 kafka-broker 的地址，因为zk获取到的 kafka-broker 地址, 不一定能直接连接成功。


# 增加如下配置
bootstrap.servers=192.168.0.1:9093

sasl.mechanism=PLAIN
security.protocol=SASL_PLAINTEXT

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
                   username="{clusterId}.{appId}" \
                   password="{password}";


producer.sasl.mechanism=PLAIN
producer.security.protocol=SASL_PLAINTEXT
producer.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
                            username="{clusterId}.{appId}" \
                            password="{password}";


consumer.sasl.mechanism=PLAIN
consumer.security.protocol=SASL_PLAINTEXT
consumer.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
                            username="{clusterId}.{appId}" \
                            password="{password}";

1.2 KiB Raw Permalink Blame History Unescape Escape

Kafka-Connect 接入 Kafka

配置

1.2 KiB

Raw Permalink Blame History