我正在使用KafkaTemplate向Kafka写入消息。我想从KafkaTemplate收集一些指标。我在我的项目中使用MicroMeter进行指标收集。如何通过MeterRegistry公开KafkaTemplate指标？
浏览 14提问于2020-04-21得票数 1
回答已采纳
我有一个spring boot应用程序(版本2.3.4)，我正在使用@KafkaListener来消费记录。我还使用了执行器和千分尺(1.5.5版)作为度量标准。问题是我看不到/actuator/prometheus中的Kafka指标。我使用了以下依赖关系： 'org.springframework.boot' version '2.3.4.RELEASE'
implementation group: 'org.springframework.kafka
浏览 102提问于2021-01-19得票数 0
我们有多个节点的spring-boot app，并使用KafkaTemplate生成kafka消息。在类路径中，我们同时拥有org.springframework.kafka:spring-kafka和io.micrometer:micrometer-core。org.springframework.kafka.support.micrometer.MicrometerHolder.success(MicrometerHolder.java:93)
at org.springframework.kafka.core
浏览 47提问于2020-07-01得票数 1
回答已采纳
(KafkaTemplate<String, byte[]> kafkaTemplate, ObjectMapper objectMapper) { this.objectWriter = objectMapper.writer(); <
浏览 1提问于2018-04-05得票数 1
回答已采纳
我的环境上下文如下所示：- Maven Multi Module project (this is a module, it imports its Springspring-boot-dependencies</artifactId>
浏览 42提问于2022-04-19得票数 0
回答已采纳
我在spring boot中使用cron表达式安排了一个作业。当我添加maven spring-kafka依赖项时，我的工作没有启动。这是我的pom.xml中的依赖项： <dependency> <artifactId>spring-boot-starter-testprefix = "pushItems",
浏览 24提问于2020-09-28得票数 0
1回答
我正在使用Spring & Kafka为一个事务性项目做POC，我有以下疑问：
场景： One微服务MSPUB1接收来自客户的请求。从MSPUB1了解主题TRANSACTION_RESULT1上的消息是否与他的原始请求匹配的最佳方法是什么？
浏览 0提问于2018-01-19得票数 1
2回答
我正在开发Spring Boot + Apache Kafka示例。当把TOPIC发送给卡夫卡的时候，出错了。(SpringApplication.java:797) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:324) [spring-boot-2.1.1.RELEAS
浏览 15提问于2018-12-16得票数 5
回答已采纳
MyKafkaProducer.class);
private String topic;
KafkaTemplate<String, String> kafkaTemplate;
public void sendDataToKafka(@RequestParam String data) {ListenableFuture<SendResult<String, String
浏览 11提问于2020-08-26得票数 0
为了从服务中获取指标，我使用了spring boot actuator (服务是用spring boot 2.0编写的)，以及测微仪和普罗米修斯。现在大约10分钟后，我的服务停止提供指标，这可能是因为URL中有很多不同的值，导致了大量的http_server_requests_seconds_sum指标。我想禁用此指标，或者可能对所有端点进行分组。
浏览 8提问于2018-11-07得票数 2
1回答
卡夫卡卡夫卡开机时出错
、、、
<String, PriceRangeModel> kafkaTemplate(){ at org.springframework.kafka.core.KafkaTemplate.doSend(KafkaTemplate.java</groupId>
<ar
浏览 2提问于2020-05-05得票数 0
2回答
我正在构建一个Spring Boot 2.4.4应用程序，使用模式验证向Kafka (Confluent Platform)生成消息。该模式是在该主题的模式注册表中设置的，我已经使用Maven Avro插件从相关的AVSC文件创建了POJO (LoanInitiate)。@Autowiredprivate
浏览 293提问于2021-04-23得票数 1
我正在尝试使用Spring Boot应用程序中的 KafkaTemplate来向Kafka主题写入消息。:759) [spring-boot-1.4.0.RELEASE.jar:1.4.0.RELEASE]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:369) [spring-boot-1.4.0.RELEASE.jar:
浏览 3提问于2016-08-08得票数 1
回答已采纳
Spring BOOT 1.5.6的性能问题spring.mvc.async.properties.web.executor.maxPoolSize=100
spring.mvc.async.properties
浏览 1提问于2018-11-08得票数 0
经过一些研究，我发现有一个弹簧执行器项目，用于监控和记录有关应用程序的信息。这里的链接建议如何将日志放入我自己的自定义存储库以进行后期处理。[ ]这似乎是业务应用程序中的一个常见问题，而且应该已经有了解决方案，所以我想知道是否有更简单的方法来实现这一点。
浏览 1提问于2018-03-02得票数 1
producerConfig和application.yml中都特别将其设置为JsonSerializer，如下所示 returnnew KafkaTemplate
浏览 11提问于2022-09-23得票数 0
回答已采纳
如何从Spring应用程序中获取appinsight中的日志？我不想要官方文档建议的指标。有没有一种方法可以对跟踪、异常表执行自定义查询，并为Spring Boot应用程序提取结果？
浏览 14提问于2020-07-27得票数 0
在我的spring boot kafka publisher应用程序中，我希望支持以字符串( json )或字节格式发布消息，因为我希望同时支持json和avro。但是spring boot中的Kafka模板让我们只定义其中的一个模板。有没有办法同时使用两个模板或任何其他方式来提供对json和avro的支持？KafkaTemplate<String, String>只适用于字符串，但我也想发布avro，它应该类似于KafkaTemplate<String, byte[]
浏览 66提问于2019-09-12得票数 3
回答已采纳
我试图使用Micrometer的@Timed注释从我的Spring Boot应用程序向Prometheus发送数据，但看到了奇怪的行为。我包含了必要的库，并遵循Spring Boot配置说明添加了Micrometer @Timed注释。在构建指标的密钥时，感觉像是Spring Boot /微米错误。:180) ~[spring-boot-actuator-2.1.9.RELEASE.jar!(WebMvcM
浏览 88提问于2020-01-22得票数 3
@Bean return new KafkaTemplate<>(producerFactory@Autowired但是当我试图编译我的代码时，我会遇到这个错误
Field kafkaTemplate in另外，如果我试图在我的Spring
浏览 3提问于2020-09-09得票数 0
云服务器
ICP备案
云直播
对象存储
即时通信 IM
腾讯云开发者
