小编May*_*yur的帖子

Kafka - 如何使用 @KafkaListener(topicPattern="${kafka.topics}") ,其中属性 kafka.topics 是“sss.*”?

我正在尝试以主题名称作为模式来实现 Kafka 消费者。例如 @KafkaListener(topicPattern="${kafka.topics}") 其中属性 kafka.topics 是 'sss.*'。现在,当我向主题“sss.test”或任何其他主题名称(如“sss.xyz”、“sss.pqr”)发送消息时,它会抛出如下错误:

警告 o.apache.kafka.clients.NetworkClient - 获取相关 ID 为 12 的元数据时出错:{sss.xyz-topic=LEADER_NOT_AVAILABLE}

我尝试在 server.properties 文件中启用侦听器和 Advertisingd.listeners,但是当我重新启动 Kafka 时,它会消耗来自已尝试的所有旧主题的消息。当我使用新的主题名称时,它会抛出上述错误。

Kafka不支持模式匹配?或者我缺少一些配置?请建议。

consumer apache-kafka spring-kafka

5
推荐指数
0
解决办法
4441
查看次数

Spring Boot Slf4j 更改日志时间戳以使用 UTC 时区

具有默认记录器设置并使用 lombok 的 Spring Boot 应用程序 @Slf4j

打印日志,例如 {"timestamp":"2020-02-26T11:25:57.485-05:00" ..........} 11:25 显示的时间是美国东部标准时间或纽约时区

我们如何将其更改为以 UTC 时区记录时间戳?

我试过设置

logging: pattern: dateformat: yyyy-MM-dd HH:mm:ss.SSS, UTC

还可以使用设置 JVM 级别的 timzone

@PostConstruct TimeZone.setDefault(TimeZone.getTimeZone("UTC"));

并尝试在 application.yaml 中进行配置
logging: pattern: console: '%d{"yyyy/MM/dd HH:mm:ss,SSS,UTC"} [%p] [%t] %M\(%F:%L\) - %msg%n'

logging slf4j lombok spring-boot

2
推荐指数
1
解决办法
3288
查看次数