我正在尝试以主题名称作为模式来实现 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不支持模式匹配?或者我缺少一些配置?请建议。
具有默认记录器设置并使用 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'