嗨,我在运行Kafka连接码头图片
docker run -d \
--name=kafka-connect \
--net=host \
-e CONNECT_BOOTSTRAP_SERVERS=localhost:39092 \
-e CONNECT_REST_PORT=28082 \
-e CONNECT_GROUP_ID="quickstart" \
-e CONNECT_CONFIG_STORAGE_TOPIC="quickstart-config" \
-e CONNECT_OFFSET_STORAGE_TOPIC="quickstart-offsets" \
-e CONNECT_STATUS_STORAGE_TOPIC="quickstart-status" \
-e CONNECT_KEY_CONVERTER="io.confluent.connect.avro.AvroConverter" \
-e CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL="http://localhost:8081" \
-e CONNECT_VALUE_CONVERTER="io.confluent.connect.avro.AvroConverter" \
-e CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL="http://localhost:8081" \
-e CONNECT_INTERNAL_KEY_CONVERTER="io.confluent.connect.avro.AvroConverter" \
-e CONNECT_INTERNAL_VALUE_CONVERTER="io.confluent.connect.avro.AvroConverter" \
-e CONNECT_REST_ADVERTISED_HOST_NAME="localhost" \
-e CONNECT_ZOOKEEPER_CONNECT="localhost:2181" \
tim/kafka-connect
以及获得
Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing Schema registry url!
at io.confluent.connect.avro.AvroConverter.configure(AvroConverter.java:64)
at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:93)
at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)
无法确定在何处添加“schema.registry.url”conf!!
2条答案
按热度按时间bd1hkmkf1#
问题出在
_INTERNAL_KEY_
以及_INTERNAL_VALUE_
我为这两个添加schema\u registry\u url的方式与为这两个添加schema\u registry\u url的方式不同_KEY_CONVERTER
以及_KEY_VALUE
不管我是怎么换回来的org.apache.kafka.connect.json.JsonConverter
对于内部键和值pdtvr36n2#
如果你用的是
.properties
文件,您将需要:如果要传入命令行环境变量,则需要: