Question

1
Replies
89
Views
NagaSanthoshKumaA8333 Member since 2019 2 posts
ING Bank NV
Posted: 1 year ago
Last activity: 1 year 3 months ago
Closed

Connection to KAFKA in Pega 7.3.0 using AvroDeserialization

Anybody made a connection to Apache Kafka using avro deserialization in Pega 7.3.0?

We are able to make connection normally but avro deserialization fails with a weird exception.

org.apache.kafka.common.KafkaException: io.confluent.kafka.serializers.KafkaAvroDeserializer is not an instance of org.apache.kafka.common.serialization.Deserializer
	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:304) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:702) ~[kafka-clients-2.1.0.jar:?]
	... 71 more
2019-05-31 17:46:29,348 [http-nio-8080-exec-9] [  STANDARD] [                    ] [   EventBus:01.01.01] (      internal.mgmt.Executable) ERROR localhost|0:0:0:0:0:0:0:1 Admin.EventBus - Exception

***Edited by Moderator: Lochan to update platform capability tags***

Data Integration Java and Activities Data Integration Decision Management
Moderation Team has archived post
Share this page LinkedIn