lutz
01/22/2021, 10:17 PMtim
01/28/2021, 12:16 PMJúlio Santos
08/06/2021, 2:50 PMAdam S
08/08/2022, 8:58 PMJoão Gabriel Zó
09/30/2022, 12:40 PMConnection Refused
and running my tests.
I’m currently using http://${schemaRegistryContainer.host}:8081
as the URL.
Anybody ever gone through something like it or any ideas on how to fix it?Michael Petri
10/21/2022, 12:41 PM[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 7.1.0-ccs
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: c86722379ab997cc
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1666355905650
[kafka-admin-client-thread | adminclient-1] INFO org.apache.kafka.common.utils.AppInfoParser - App info kafka.admin.client for adminclient-1 unregistered
[kafka-admin-client-thread | adminclient-1] INFO org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed
[kafka-admin-client-thread | adminclient-1] INFO org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter
[kafka-admin-client-thread | adminclient-1] INFO org.apache.kafka.common.metrics.Metrics - Metrics reporters closed
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/kafka/common/config/ConfigDef$ListSize
at org.apache.kafka.streams.StreamsConfig.<clinit>(StreamsConfig.java:821)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:738)
at MainKt.main(Main.kt:30)
Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.config.ConfigDef$ListSize
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
... 3 more
Any idea how to debug this?Michael Petri
10/25/2022, 7:08 AMMichael Petri
02/13/2023, 12:26 PMArrayList<String>
Here my aggregate call
.aggregate(
{ ArrayList<String>() },
{ _, event, history ->
history.add(event)
history
},
Materialized.with(
Serdes.Long(),
Serdes.ListSerde(
ArrayList::class.java,
Serdes.StringSerde()
)
)
)
and in the screenshot the error.
Maybe someone has an idea 🙏
Thanks!