我现在正在玩SpringBootV2。到目前为止，我的设置是这样的：spring->telegraf->kafka->telegraf->inflox
我想知道是否有可能把斯普林和Kafka之间的第一个电传机取出来，这样的话：斯普林->Kafka->电传机->涌入
我看了千分尺的配置，没有Kafka的配置。另外，telegraf还在从spring提取数据。。由于kafka是一个push模型（即，您正在将数据推入kafka），spring是否能够将数据推入kafka？如果是，怎么做？通过使用httppost方法？
全新概念。
1条答案
按热度按时间kcugc4gi1#
spring能把数据推给Kafka吗？如果是，怎么做？通过使用httppost方法？
kafka使用自己的tcp协议，而不是http，所以不，至少没有kafka rest代理。
基本上，您将在spring代码中嵌入telegraf所做的事情。
这是可能的，当然，但是内置在千分尺里？我不知道。
另外，如果你的应用程序有一个内部生产者线程，那么这将是一个开销，而且你需要在每个被监视的应用程序中包含kafka客户端，另外，如果kafka连接不可能，你还需要一些控制来防止你的应用程序失败。。。
我建议在每台主机上安装telegraf，或者至少为您的个别java应用程序安装prometheus jmx exporter或jolokia。由此，可以收集jmx度量并将其推送到下游监控系统
或者，正如评论所说，你可以跳过Kafka，但我猜你想把它作为一个缓冲。
另一方面，您可以使用kafka-xdb-sink来获得最佳的用户扩展性能