如何使用kafka连接和XML配置文件配置测试环境

Question

我是 Kafka 的新手，我写了一段写入主题的代码（制作人）。

现在，我被赋予了一项任务，即观察内容是否与主题相关。

我的技术主管提供的唯一信息是我应该安装kafka连接，并使用此XML：

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<connections>
<connection bootstrap_servers="xxxxxxxxxx.c3.kafka.eu-west-3.amazonaws.com:9096,xxxxxxxxxx.c3.kafka.eu-west-3.amazonaws.com:9096,xxxxxxxxxx.c3.kafka.eu-west-3.amazonaws.com:9096" broker_security_type="SASL_SSL" chroot="/" group="Clusters" groupId="1" host="xxxxxxxxxx.c3.kafka.eu-west-3.amazonaws.com" jaas_config="org.apache.kafka.common.security.scram.ScramLoginModule required username=&quot;USER&quot; password=&quot;PASSWD&quot;;" keystore_location="" keystore_password="" keystore_privatekey="" name="Worten" port="9096" sasl_mechanism="SCRAM-SHA-512" schema_registry_endpoint="" truststore_location="" truststore_password="" version="VERSION_2_7_0"/>
<groups>
<group id="1" name="Clusters"/>
</groups>
</connections>

我完全不知道在哪里或如何导入这个xml配置文件。我安装了kafka，将其放到本地运行，但所有配置文件通常采用以下格式：

$cat-config/connect-standalone.properties

部分输出:

bootstrap.servers=xxxxxxxxx.c3.kafka.eu-west-3.amazonaws.com:9096,xxxxxxxxx.c3.kafka.eu-west-3.amazonaws.com:9096,xxxxxxxxx.c3.kafka.eu-west-3.amazonaws.com:9096

# The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will
# need to configure these based on the format they want their data in when loaded from or stored into Kafka
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
# Converter-specific settings can be passed in by prefixing the Converter's setting with the converter we want to apply
# it to
key.converter.schemas.enable=true
value.converter.schemas.enable=true

offset.storage.file.filename=/tmp/connect.offsets
# Flush much faster than normal, which is useful for testing/debugging
offset.flush.interval.ms=10000

我尝试在这里添加字段，但缺少许多字段，任何提示都将非常受欢迎，我做了一些研究，但我找不到太多对我有帮助的东西。

谢谢！！！

我试着搜索任何允许我启动本地独立消费者集群的东西，这样我就可以看到我要写的主题。

Answer 1

Kafka Connect 不使用 XML 文件。它仅使用 Java .properties 文件。

您显示的属性文件缺少SASL_SSL值，这些值在您获得的XML中提到。

Kafka 快速入门介绍了运行 Kafka Connect 独立模式，你可以参考配置属性的文档，例如使用者或生产者。 需要使用 SASL/SSL 值配置的属性，例如 consumer.sasl.mechanism=SCRAM-SHA-512