如何在没有抛出错误的情况下为Clickhouse配置Kafka？
我有两个Kafka集群，第一个-Kafka-A-使用“SASL SCRAM-SHA-256”机制进行身份验证，另一个-Kafka-B-没有为其设置配置。
为了能够连接到Clickhouse中的< code>Kafka-A,我配置了一个< code>config.xml文件，如下所示:
<kafka>
<security_protocol>sasl_plaintext</security_protocol>
<sasl_mechanism>SCRAM-SHA-256</sasl_mechanism>
<sasl_username>xxx</sasl_username>
<sasl_password>xxx</sasl_password>
<debug>all</debug>
<auto_offset_reset>latest</auto_offset_reset>
<compression_type>snappy</compression_type>
</kafka>
在这一点上，我发现我无法使用Kafka引擎表连接到Kafka-B。当我尝试发生打印以下消息的错误时：
storage Kafka(XXX):[rdk:FAIL][thrd:sasl _ plaintext://XXX/bootstrap]:sasl _ plaintext://XXX/bootstrap:sasl紧急停堆-SHA-256机制握手失败:代理:请求在当前SASL状态下无效:代理支持的机制:(在AUTH_HANDSHAKE状态下3毫秒后，4个相同的错误被抑制)
似乎在连接到< code>Kafka-B时，Clickhouse也使用SASL认证，这导致抛出错误，因为< code>Kafka-B服务器没有配置认证。
我想知道如何正确配置它以连接到不同的 Kafka 集群？
共有1个答案
CH允许为每个主题定义kafka配置
在XML节的名称中使用主题:
<kafka_mytopic>
<security_protocol>....
....
</kafka_mytopic>
-
我刚刚通过nodejs.org上的软件包安装了node和npm，每当我试图搜索或安装npm时，它都会抛出以下错误，除非我执行该命令。我觉得这是一个权限问题？我已经是管理员了。
-
我只是通过nodejs.org上的包安装了node和npm，每当我试图搜索或安装带有npm的东西时，它会抛出以下错误，除非我sudo该命令。我觉得这是个权限问题？我已经是管理员了。
-
问题内容： 我正在尝试设置spring xml配置，而不必创建进一步的。但是，即使我将数据库属性包括在 spring.xml： 我在这里想念什么？ 问题答案： 在entityManagerFactory bean定义中指定“ packagesToScan”和“ persistenceUnitName”属性。 请注意，这适用于Spring版本> 3.1
-
问题内容： 我正在尝试编写一个执行脚本；但是，如果没有要提交的内容，则git会退出，状态为。部署脚本将其视为不成功，然后退出。我确实想检测 实际 要提交的故障，因此我不能仅仅给Fabric全面忽略故障。如何允许忽略空提交故障，以便部署可以继续进行，但仍然可以捕获实际提交失败时导致的错误？ 问题答案： 通过检查git diff？的退出代码来预先捕获此条件。 例如（在shell中）： 编辑：根据霍尔格
-
我正在使用Spring框架和Hibernate开发一个web应用程序。我的问题是，我经常收到404错误，这是因为我在代码库的某个地方犯了一个错误，但控制台中没有异常消息。正因为如此，我很难找到错误在哪里，因为项目已经变得非常大，手动尝试找到问题是不切实际的。我假设是Spring导致了这个问题，所以我的问题是：是否有某种方法可以启用更详细的错误消息？谢谢
-
我正在尝试设置SpringXML配置，而不必创建进一步的。但是我经常遇到以下异常，即使我在 spring.xml： 我错过了什么？