「スキーマレジストリのURLがありませんが、」

Question

こんにちはイムは、カフカ接続ドッキングウィンドウの画像

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) 

「スキーマを追加する場所を

理解できません.registry.url "conf !!

Answer 1

問題が_INTERNAL_KEY_と_INTERNAL_VALUE_
私はこれらの2のために、私は_KEY_CONVERTERと_KEY_VALUE私は内部キーと値

Answer 2

ためorg.apache.kafka.connect.json.JsonConverterに戻しどのような方法のためにやったのと同じ方法をSCHEMA_REGISTRY_URLを追加していなかったとありましたあなたが.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