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
DEVTEST 10.7.2 and up.
Consumer topic did not have READ option.. As VSM is trying to listen on this topic, we got Not authorized message.
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.