将自定义kafka使用者与Spring cloud config客户端集成
共有1个答案
甚至比这更简单。如果查看refreshlistener类，可以看到它所做的只是
Set<String> keys = this.contextRefresher.refresh();
log.info("Received remote refresh request. Keys refreshed " + keys);
其中contextrefresher是org.springframework.cloud.context.refresh.contextrefresher。
这将触发处理自动查找配置的代码。
-
问题内容： 我正在与socket.io聊天应用程序，我想用我的自定义客户端ID，而不是默认的（，）。连接时是否有任何发送自定义标识符的方式，或仅使用某种方式来跟踪每个ID的自定义名称？谢谢！ 问题答案： 您可以在服务器上创建一个数组，并在其上存储自定义对象。例如，您可以存储Socket.io创建的ID和每个客户端发送到服务器的自定义ID： 在此示例中，您需要从每个客户端调用 storeClient
-
我在kafka消费者文档中看到了这个注释-
-
我目前正在努力掌握Spring和Fign。开门见山：我正在努力修改这个项目中的“飞度客户端”： Walery的“飞度你好世界”，以便代替 维基百科 使用@Autowired表示法，类似于此处的一个表示法：部分名为：手动创建外部客户端 这样做的目的是稍后注入自定义解码器和编码器。我已经尝试了一段时间，我所能实现的就是破坏整个事情。 我从这里和那里收集了一些线索，并设法到达了创建Configurati
-
我正在实现一个自定义消费者的主题/分区分配在Kafka。为此，我将重写抽象类，该类又实现接口。 作为自定义赋值器的一部分，我希望发送一个关于消费者订阅的每个主题的每个分区的单个（浮动）信息。 我知道可以通过重写接口的默认方法向赋值器发送自定义数据。 但是，问题是，从上面的方法签名中，我无法获得为使用者注册的每个主题分配给带下划线使用者的分区列表。 谢谢你。
-
我使用新的API创建了一个kafka消费者（http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/kafkaConsumer.html） 当前，使用者正在从最小的偏移量开始读取主题中的消息。我想重写这个以读取最新的偏移量。有什么关于如何做到这一点的指示吗？
-
我在Jmeter中执行API时遇到了问题。我们的API中有客户端证书。pfx格式。我已经把它换成了。jks，并在系统中进行了更新。jmeter的特性。在jmeter中，我创建了一个csv文件来获取创建的别名。但是，错误显示为 错误：响应消息：非HTTP响应消息：java.lang.IllegalArgumentException：未找到别名的证书：'certalias' 以下是我的别名信息：别名：