Carlos Santana

@rabbah this is similar in spirit what I’m doin in swift4 with Codable IN and Codable OUT?

I prefer to invest engineering resources into proper queuing into the next phase of the message/event pipeline, meaning that the trigger fire should post message to the OpenWhisk kafka bus...

I still don’t get it what dedicated “topic” you speak about? This provider doesn’t have a kafka instance, are you referring a single dedicated “triggers” topic on the main kafka...

Wait a second? Isn’t the provider can already use the incoming topic as persistence? Meaning if the retry doesn’t work in a timing manner we can choose not to drop...

Agree we should not expose the implementation details and keep the abstraction of the interface to the user the same so massaging the keys is a good thing.

@abaruni Could you change READ config object to match the input parameters by user based on feedback from @jberstler above ^^ https://github.com/apache/incubator-openwhisk-package-kafka/issues/220#issuecomment-343330248 >I would argue that when retrieving the trigger...

I did a quick look it looks like there are 2 fields to change username -> user brokers -> kafka_brokers_sasl ```json { "kafka_brokers_sasl": [ "kafka01-prod01.messagehub.services.us-south.bluemix.net:9093", "kafka02-prod01.messagehub.services.us-south.bluemix.net:9093", "kafka03-prod01.messagehub.services.us-south.bluemix.net:9093", "kafka04-prod01.messagehub.services.us-south.bluemix.net:9093", "kafka05-prod01.messagehub.services.us-south.bluemix.net:9093" ],...

It's definitely `user` here in produce action https://github.com/apache/incubator-openwhisk-package-kafka/blob/master/action/messageHubProduce.py#L124

It's definitely `user` here in MessageHubFeedWeb Action https://github.com/apache/incubator-openwhisk-package-kafka/blob/master/action/messageHubFeedWeb.js#L145 But stored as `username` in db, so we need the get to change to `user` in the way out https://github.com/apache/incubator-openwhisk-package-kafka/blob/master/action/messageHubFeedWeb.js#L84-L86 it is...

From the readme on generic kafka meaning no Bluemix https://github.com/apache/incubator-openwhisk-package-kafka/blob/master/README.md#creating-a-trigger-that-listens-to-a-generic-kafka-instance If only one host then just use :9092 no need for 9093 host No need to pass any user or...