Support Questions

Find answers, ask questions, and share your expertise
Announcements
Check out our newest addition to the community, the Cloudera Data Analytics (CDA) group hub.

SAM Kafka-env not found

I have a SAM instance which is connecting to a remote Kafka instance. It was added manually to the Environment and Service pool in SAM, before using it in a SAM application. In my application I can drag it to the Canvas, but when I double click on it to configure, it throws an error on screen "An exception with message [com.hortonworks.streamline.streams.catalog.exception.ServiceConfigurationNotFoundException: Configuration [kafka-env] not found for service [KAFKA] in cluster with id [5]] was thrown while processing request."

A more detailed error message from the logs:

p.p1 {margin: 0.0px 0.0px 0.0px 0.0px; font: 12.0px 'Andale Mono'; color: #28fe14; background-color: #000000; background-color: rgba(0, 0, 0, 0.9)} span.s1 {font-variant-ligatures: no-common-ligatures}

ERROR[14:34:31.032] [dw-352 - GET /api/v1/catalog/streams/componentbundles/SOURCE/1/hints/namespaces/1] c.h.s.s.s.TopologyComponentBundleResource -Got exception: [RuntimeException] / message [com.hortonworks.streamline.streams.catalog.exception.ServiceConfigurationNotFoundException: Configuration [kafka-env] not found for service [KAFKA] in cluster with id [5]] / related resource location: [com.hortonworks.streamline.streams.service.TopologyComponentBundleResource.getFieldHints](TopologyComponentBundleResource.java:539)

java.lang.RuntimeException: com.hortonworks.streamline.streams.catalog.exception.ServiceConfigurationNotFoundException: Configuration [kafka-env] not found for service [KAFKA] in cluster with id [5]

at com.hortonworks.streamline.streams.cluster.bundle.AbstractKafkaBundleHintProvider.getSecurity(AbstractKafkaBundleHintProvider.java:37)

at com.hortonworks.streamline.streams.cluster.bundle.AbstractSecureBundleHintProvider.provide(AbstractSecureBundleHintProvider.java:32)

at com.hortonworks.streamline.streams.service.TopologyComponentBundleResource.getFieldHints(TopologyComponentBundleResource.java:539)

.

.

.

1 REPLY 1

We ended up installing a Kafka service in HDF where SAM resides to resolve this issue.

Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.