Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

Too many WARN messages #1858

Open
asafm opened this issue May 22, 2023 · 0 comments
Open

Too many WARN messages #1858

asafm opened this issue May 22, 2023 · 0 comments

Comments

@asafm
Copy link
Contributor

asafm commented May 22, 2023

I have modified my docker-compose-cluster.yaml to be exactly like the one in kop (I think the main change was version upgrade to streamnative/sn-pulsar:2.11.1.0).

The only thing that different compared to Kafka is the WARN from the client

[2023-05-14 17:59:14,610] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1333 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)

This WARN appears many times. Here is the log for it:

[2023-05-14 17:58:59,269] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 2 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:00,797] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 7 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:00,985] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 66 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:01,140] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 97 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:01,322] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 118 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:01,497] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 144 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:01,675] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 173 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:03,380] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 199 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:03,868] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 229 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:04,099] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 259 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:04,898] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 277 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:06,564] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 298 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:07,238] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 616 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:07,427] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 685 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:08,346] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 706 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:08,698] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 749 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:08,938] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 760 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:10,101] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 776 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:10,606] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 904 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:10,756] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1008 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:10,907] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1036 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:11,058] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1055 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:11,205] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1079 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:11,360] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1105 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:11,515] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1118 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:11,656] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1147 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:11,833] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1167 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:11,986] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1203 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:12,137] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1236 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:12,292] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1277 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:12,432] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1309 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:12,566] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1319 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:12,700] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1320 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:12,844] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1321 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:12,980] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1322 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:13,134] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1323 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:13,275] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1324 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:13,412] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1325 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:13,571] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1326 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:13,735] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1327 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:13,877] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1328 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:14,026] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1329 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:14,170] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1330 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:14,311] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1331 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:14,464] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1332 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:14,610] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1333 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:14,743] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1334 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:14,882] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1335 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:15,012] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1336 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:15,146] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1337 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:15,275] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1338 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:15,411] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1339 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:15,558] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1340 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 17:59:15,690] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 1341 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)

This is how it looks like when running the example, against Kafka:

[2023-05-14 18:11:48,635] WARN [main] Using an OS temp directory in the state.dir property can cause failures with writing the checkpoint file due to the fact that this directory can be cleared by the OS. Resolved state.dir: [/var/folders/kc/tw2ty9r11f34925hs5ff_3yh0000gn/T//kafka-streams] (org.apache.kafka.streams.processor.internals.StateDirectory)
[2023-05-14 18:11:48,855] WARN [main] Error while loading kafka-streams-version.properties (org.apache.kafka.streams.internals.metrics.ClientMetrics)
java.lang.NullPointerException: inStream parameter is null
	at java.base/java.util.Objects.requireNonNull(Objects.java:233)
	at java.base/java.util.Properties.load(Properties.java:408)
	at org.apache.kafka.streams.internals.metrics.ClientMetrics.<clinit>(ClientMetrics.java:53)
	at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:894)
	at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:856)
	at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:826)
	at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:738)
	at io.confluent.examples.streams.AnomalyDetectionLambdaExample.main(AnomalyDetectionLambdaExample.java:159)
[2023-05-14 18:11:48,988] WARN [main] stream-thread [main] Failed to delete state store directory of /var/folders/kc/tw2ty9r11f34925hs5ff_3yh0000gn/T/kafka-streams/anomaly-detection-lambda-example for it is not empty (org.apache.kafka.streams.processor.internals.StateDirectory)
[2023-05-14 18:11:49,052] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 2 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2023-05-14 18:11:49,157] WARN [anomaly-detection-lambda-example-client-StreamThread-1] [Consumer clientId=anomaly-detection-lambda-example-client-StreamThread-1-consumer, groupId=anomaly-detection-lambda-example] Error while fetching metadata with correlation id 7 : {anomaly-detection-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000002-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)

Originally posted by @asafm in #1743 (comment)
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@asafm