From 1ef7bde8749b0ef33107f69d00a3cfc9ca7bd8c2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ji=C5=99=C3=AD=20Hofman?= <jiri.hofman@gmail.com>
Date: Tue, 8 Apr 2025 08:17:42 +0200
Subject: [PATCH] Sonar refactoring - jsdoc

---
 src/appmixer/aws/aws-commons.js   | 6 +++---
 src/appmixer/kafka/connections.js | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

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