使用avro converter运行kafka connect:configexception:“缺少架构注册表url”

xxslljrj  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(284)

嗨,我在运行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!!

bd1hkmkf

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 对于内部键和值

pdtvr36n

pdtvr36n2#

如果你用的是 .properties 文件,您将需要:

:internal.key.converter.schema.registry.url http://urlgoes.here
:internal.value.converter.schema.registry.url http://urlgoes.here

如果要传入命令行环境变量,则需要:

INTERNAL_KEY_CONVERTER_SCHEMA_REGISTRY_URL=http://urlgoes.here
INTERNAL_VALUE_CONVERTER_SCHEMA_REGISTRY_URL=http://urlgoes.here

相关问题