diff --git a/src/appmixer/aws/aws-commons.js b/src/appmixer/aws/aws-commons.js
index 87eb871d4..5a2d36fec 100644
--- a/src/appmixer/aws/aws-commons.js
+++ b/src/appmixer/aws/aws-commons.js
@@ -46,9 +46,9 @@ module.exports = {
      * Create and subscribe topic to AWS SNS.
      * @param {Context} context
      * @param {Object} payload
-     * @param {Object} payload.topicPrefix
-     * @param {Object} payload.eventPrefix
-     * @param {Object} payload.eventType
+     * @param {string} payload.topicPrefix
+     * @param {string} payload.eventPrefix
+     * @param {string} payload.eventType
      * @return {Promise}
      */
     async registerWebhook(context, payload) {
diff --git a/src/appmixer/kafka/connections.js b/src/appmixer/kafka/connections.js
index affa72eb8..37949847d 100644
--- a/src/appmixer/kafka/connections.js
+++ b/src/appmixer/kafka/connections.js
@@ -187,7 +187,7 @@ const loadConsumerOptions = function(context) {
  * @param {Object} auth Authentication configuration
  * @param {string} connId Optional connection ID
  * @param {number} partitionsConsumedConcurrently Number of partitions to consume concurrently (default: 3)
- * @returns {string} The connection ID
+ * @returns {Promise<string>} The connection ID of the created consumer
  */
 const addConsumer = async (
     context, topics, flowId, componentId, groupId, fromBeginning, auth, connId, partitionsConsumedConcurrently = 3