kafka-to-hdfs/connect-avro-standalone.properties文件

lztngnrs  于 2021-06-01  发布在  Hadoop
关注(0)|答案(0)|浏览(233)

我想连接日志文件kafka并将其作为.avro文件移动到hdfs。但是我还没有决定应该使用哪种转换器。如何组织此文件?
confluent-3.2.1/etc/schema registry/connect-avro-standalone.properties

bootstrap.servers=localhost:9092

key.converter=io.confluent.connect.avro.AvroConverter
key.converter=org.apache.kafka.connect.storage.StringConverter
key.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schema.registry.url=http://localhost:8081

value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://localhost:8081

internal.key.converter=org.apache.kafka.connect.json.JsonConverter
internal.value.converter=org.apache.kafka.connect.json.JsonConverter

internal.key.converter=org.apache.kafka.connect.storage.StringConverter
internal.value.converter=org.apache.kafka.connect.storage.StringConverter

internal.key.converter.schemas.enable=true
internal.value.converter.schemas.enable=true

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题