search

IBMStreams / streamsx.messagehub

Repository to provide easy integration with IBM MessageHub Bluemix Service
https://ibmstreams.github.io/streamsx.messagehub/
Apache License 2.0
1 stars 6 forks source link

Operators fail to parse credentials #91

Closed ghost closed 5 years ago

ghost commented 5 years ago

Credentials of a new created Event Streams instance cannot be used as the check for kafka_rest_url fails:

com.ibm.streamsx.messagehub.credentials.InvalidCredentialsException: 'kafka_rest_url' could not be parsed from JSON.
 - com.ibm.streamsx.messagehub.credentials.MessageHubCredentials.validate(MessageHubCredentials.java:67)
 - com.ibm.streamsx.messagehub.operators.utils.ServiceCredentialsUtil.loadPropertiesFromCredsString(ServiceCredentialsUtil.java:276)
 - com.ibm.streamsx.messagehub.operators.utils.ServiceCredentialsUtil.loadPropertiesFromFromAppConfigCreds(ServiceCredentialsUtil.java:192)
 - com.ibm.streamsx.messagehub.operators.utils.ServiceCredentialsUtil.loadFromAppConfigCredentials(ServiceCredentialsUtil.java:116)
 - com.ibm.streamsx.messagehub.operators.MessageHubConsumerOperator.loadFromAppConfig(MessageHubConsumerOperator.java:121)
 - com.ibm.streamsx.kafka.operators.AbstractKafkaOperator.loadProperties(AbstractKafkaOperator.java:163)
 - com.ibm.streamsx.messagehub.operators.MessageHubConsumerOperator.loadProperties(MessageHubConsumerOperator.java:112)
 - com.ibm.streamsx.kafka.operators.AbstractKafkaOperator.initialize(AbstractKafkaOperator.java:128)
 - com.ibm.streamsx.kafka.operators.AbstractKafkaConsumerOperator.initialize(AbstractKafkaConsumerOperator.java:642)
 - com.ibm.streams.operator.internal.runtime.api.OperatorAdapter.initialize(OperatorAdapter.java:745)
 - com.ibm.streams.operator.internal.jni.JNIBridge.<init>(JNIBridge.java:277)

kafka_rest_url is not used.

ghost commented 5 years ago

Older Event Streams instances still contain kafka_rest_url. This bug does not affect Toolkit versions prior to version 2.0.0.

Resolved in v2.0.1