Question

1
Replies
106
Views
Naga Santhosh Kumar Arala (NagaSanthoshKumaA8333)
ING Bank NV

ING Bank NV
NL
NagaSanthoshKumaA8333 Member since 2019 2 posts
ING Bank NV
Posted: June 3, 2019
Last activity: June 3, 2019
Posted: 3 Jun 2019 5:06 EDT
Last activity: 3 Jun 2019 8:21 EDT
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 Decision Management
Moderation Team has archived post, This thread is closed to future replies. Content and links will no longer be updated. If you have the same/similar Question, please write a new Question.