Nap*_*hen 9 apache-kafka apache-kafka-streams
我们在 kotlin 中有一个 KStreams 应用程序,并从org.apache.kafka:kafka-streams:3.2.3切换到org.apache.kafka:kafka-streams:3.3.1,现在在运行时收到以下警告:
WARN org.apache.kafka.streams.internals.metrics.ClientMetrics - Error while loading kafka-streams-version.properties
java.lang.NullPointerException: inStream parameter is null
at java.util.Objects.requireNonNull(Objects.java:246) ~[?:?]
at java.util.Properties.load(Properties.java:406) ~[?:?]
at org.apache.kafka.streams.internals.metrics.ClientMetrics.<clinit>(ClientMetrics.java:53) ~[kafka-streams-3.3.1.jar:?]
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:894) ~[kafka-streams-3.3.1.jar:?]
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:856) ~[kafka-streams-3.3.1.jar:?]
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:826) ~[kafka-streams-3.3.1.jar:?]
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:738) ~[kafka-streams-3.3.1.jar:?]
Run Code Online (Sandbox Code Playgroud)
我们是否忽略了发行说明中需要更改的内容或如何处理此警告?
谢谢,马蒂亚斯
同样的问题,我们在应用程序启动时收到警告。我快速检查了它的实现ClientMetrics,似乎它需要/kafka/kafka-streams-version.properties类路径上的文件。因此,您可能可以创建该文件并将其添加到类路径中。
但是,恕我直言,如果文件是可选的,则日志不应显示为警告,而应显示为调试。
| 归档时间: |
|
| 查看次数: |
4886 次 |
| 最近记录: |