理解Kafka式的交流
我正在使用Kafka，并启用了 kerberos（SASL_PLAINTEXT使用 GSSAPI）进行 kerberos 身份验证。我试图在这里了解 kerberos 如何用于代理间身份验证，因为我在这里没有看到任何有关客户端的 jaas 配置的信息。
服务器属性：
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=GSSAPI
sasl.kerberos.service.name=kafka
advertised.listeners=SASL_PLAINTEXT://host1:9092
使用的jaas配置文件。
KafkaServer {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
storeKey=true
keyTab="/local/kafka/config/kafka_server.keytab"
principal="kafka/host1@Example.com";
};
共有1个答案
当我们谈论中间经纪人时，每个经纪人都是其他经纪人的客户。协议中，您引用的jaas配置是代理将用于通信的jaas客户端配置。你还想弄明白什么？
-
我有一个Spring Boot应用程序，可以使用和。我有一位制片人。 我想写JUnit上面没有任何嘲弄类。我尝试了，但我不确定如何将其连接到我的应用程序定义的kafka代理，所以当我发送主题消息时，消费者（其中存在）应该选择消息并处理它。 有了我也得到了下面的错误。 有人能告诉我如何在不模仿任何类的情况下为我的Kafka制作人编写Junit，它应该用真实的类进行测试。
-
我开始学习Kafka用于企业解决方案。 在我阅读的过程中，我脑海中浮现出一些问题： > 当一个生产者正在生成一个消息--它会指定它想要将消息发送到的主题，是这样吗？它关心分区吗？ 当订阅服务器运行时-它是否指定其组id，以便它可以是同一主题的使用者集群的一部分，或者是该组使用者感兴趣的几个主题的一部分？ 每个消费者组在代理上有一个对应的分区还是每个消费者都有一个？ 分区是由代理创建的，因此不是消费
-
本文向大家介绍Spring mvc JSON数据交换格式原理解析，包括了Spring mvc JSON数据交换格式原理解析的使用技巧和注意事项，需要的朋友参考一下 什么是JSON JSON(JavaScript Object Notation, JS 对象标记) 是一种轻量级的数据交换格式，目前使用特别广泛。 采用完全独立于编程语言的文本格式来存储和表示数据。 简洁和清晰的层次结构使得 JSON
-
如果我想使用交互式经纪人Java API检查当前头寸，然后通过出售或购买每个头寸的股票来重新平衡这些头寸，我只需要使用EWrapper。position（）方法获取帐户中的当前头寸？或者我应该使用EClientSocket。reqPositions（）方法来获取它？ Ewrapper似乎用于从TWS接收信息到客户端，而EClientSocket用于向TWS发送请求。在这种情况下，我是否同时使用po
-
null
-
稳定性: 2 - 稳定的 repl 模块提供了一种 读取-求值-输出 循环（REPL）的实现，它可作为一个独立的程序或嵌入到其他应用中。 可以通过以下方式使用它： const repl = require('repl'); 设计与特性 repl 模块导出了 repl.REPLServer 类。 当 repl.REPLServer 实例运行时，它接收用户输入的每一行，根据用户定义的解释函数解释这些