带有spring cloud stream的Kafka客户端id属性
有了Spring Cloud Stream，有什么方法可以设置Kafka client id属性吗？当然我用的是Kafka活页夹。我的几个设置此设置的服务将被复制，那么有什么方法可以使IDs在实例之间唯一呢？（查看Spring Kafka Consumer Client-Id配置，似乎IDs需要是唯一的。）
假设我可以设置该属性，那么在运行时是否需要查询ID？
共有1个答案
您可以通过spring-kafka项目提供的KafkaProperties的clientid属性进行设置（spring-cloud-stream使用该属性）。也就是说，我不确定我是否完全理解“...复制服务...”评论。我的意思是，我不确定你所说的spring-cloud-stream项目的范围是什么意思，它可能支持什么，也可能不支持什么。你能澄清一下吗？
-
当我尝试access/oauth/token时，我得到了错误： O.S.S.O.Provider.Endpoint.TokenEndpoint：处理错误：NoSuchClientException，没有请求ID：username的客户端 null
-
我发现maven repo中有几个Kafka。 阿帕奇的maven回购协议中有两个Kafka。https://mvnrepository.com/artifact/org.apache.kafka/kafka https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients 它们都可以从kafka服务器生成Mesg并消耗msg。 我
-
我刚开始使用Kafka，它听起来对微服务非常好，但我基本上是在Scala中工作的。 我将kafka添加到我的sbt项目中： 然后我这样做: 我这里的问题是，当我调用，它是Java的未来。我不知道Java Futures是如何工作的，我更愿意跳过这个学习曲线。这次是未来，但我指的是Java。 所以我想知道是否有完整的Scala api可以和Kafka一起使用。因为Kafka是用Scala写的，所以通
-
我对Kafka很陌生，我想了解配额制是如何为Kafka工作的。 到现在为止我一直在跟踪这里的文件 bin/kafka-configs.sh--zookeeper 10.11.10.2:2181--alter--add-config'producer_byte_rate=1024,consumer_byte_rate=1024'--实体类型客户端--实体名称客户端A 我还使用以下命令来测量Kafka
-
问题内容： 我需要连接到通过REST接口提供JSON的端点。我真的找不到以一致的方式将这两种技术结合在一起的东西。 我正在寻找一个可以让我快速入门的图书馆。 问题答案： 您可以使用Json.Net库，这个扩展类是利用了 一些用法示例： 编辑： 这是另一个没有
-
我有一个来自http工具包的Websocket连接（Clojure，它工作得很好）。我从客户端发送ping以确保我们仍然保持连接，并且在那里一切正常。我的问题是，在这种情况下，人们是否会从服务器ping客户端？ 我试图设置一些东西，如果我没有得到响应，就从服务器上删除频道，但是设置定时进程和改变状态来跟踪乒乓周期不是很方便，所以它变得有点难看。然后我就想，服务器能处理几十万个同时连接，我是不是就应