Does DevTest has Apache Kafka Listener?? Getting Not authorized to access topics message
search cancel

Does DevTest has Apache Kafka Listener?? Getting Not authorized to access topics message

book

Article ID: 279641

calendar_today

Updated On:

Products

Service Virtualization

Issue/Introduction

We were trying to implement a Apache-Kafka component, when deployed on the VSE, should be listening to some pre-configured topics.. While we were able to achieve this thorough a testCase, but unable to implement in VSE as planned.

We are seeing the below errors in the workstation logs :

============================================================================ | Exception: ============================================================================ | Message: Not authorized to access topics: [dev.sv-ism-case-changed] ---------------------------------------------------------------------------- | Trapped Exception: Not authorized to access topics: [dev.sv-ism-case-changed] | Trapped Message: org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [dev.sv-ism-case-changed] ---------------------------------------------------------------------------- STACK TRACE org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [dev.sv-ism-case-changed] ============================================================================ 2024-02-20 17:38:40,373Z (11:38) [Kafka listener thread for [dev.sv-ism-case-changed, dev.sv-ism-system-workflow-process-updated]] WARN com.itko.lisa.asset.LocalAssetRuntime - Asset instance AsyncM

Environment

DEVTEST 10.7.2 and up. 

Cause

Consumer topic did not have READ option.. As VSM is trying to listen on this topic, we got Not authorized message.

Resolution

Create  topics with READ/WRITE options with the below privileges for consumers and producers used in the VirtualService. 
Consumer = READ, Response (Producer) =WRITE/READ

After relaxing  some restrictions around the READ/WRITE privileges on the topics created on Kafka infrastructure we are now able to configure a listener, which listens to a topic and responds back with whatever I configured on the VSI to the interested topics.