You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In this repo you have a PoC in which I'm trying to run a native application with Spring Cloud Stream + Kafka Reactive using Avro messages.
If you look at the history, you'll see that I was able to make it run when I used String messages (see pipeline results here), but switching to Avro messages this example only works in a non-native environment (see pipeline results here), but it fails when it tries to run this same test in native with the following exception:
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:459)
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:287)
org.springframework.kafka.core.DefaultKafkaProducerFactory.createRawProducer(DefaultKafkaProducerFactory.java:913)
org.springframework.kafka.core.DefaultKafkaProducerFactory.createKafkaProducer(DefaultKafkaProducerFactory.java:812)
org.springframework.kafka.core.DefaultKafkaProducerFactory.doCreateProducer(DefaultKafkaProducerFactory.java:779)
[...]
Caused by: org.apache.kafka.common.KafkaException: Could not find a public no-argument constructor for io.confluent.kafka.serializers.KafkaAvroSerializer
org.apache.kafka.common.utils.Utils.newInstance(Utils.java:399)
org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:395)
org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:434)
org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:419)
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:385)
[...]
Caused by: java.lang.NoSuchMethodException: io.confluent.kafka.serializers.KafkaAvroSerializer.<init>()
java.base@21.0.2/java.lang.Class.checkMethod(DynamicHub.java:1075)
java.base@21.0.2/java.lang.Class.getConstructor0(DynamicHub.java:1238)
java.base@21.0.2/java.lang.Class.getDeclaredConstructor(DynamicHub.java:2930)
org.apache.kafka.common.utils.Utils.newInstance(Utils.java:397)
Please, could you point me in the right direction to solve this problem?
Thanks in advance for your support!
The text was updated successfully, but these errors were encountered:
Hi everyone!
In this repo you have a PoC in which I'm trying to run a native application with Spring Cloud Stream + Kafka Reactive using Avro messages.
If you look at the history, you'll see that I was able to make it run when I used String messages (see pipeline results here), but switching to Avro messages this example only works in a non-native environment (see pipeline results here), but it fails when it tries to run this same test in native with the following exception:
Please, could you point me in the right direction to solve this problem?
Thanks in advance for your support!
The text was updated successfully, but these errors were encountered: