feat: add configuration of Kafka consumer groups via environment vari…

…able
acryldata · Feb 25, 2024 · 1eeb094 · 1eeb094
1 parent 081806b
commit 1eeb094
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/docker/config/executor.yaml b/docker/config/executor.yaml
@@ -11,7 +11,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-name: "ingestion_executor" 
+name: ${DATAHUB_ACTIONS_INGESTION_EXECUTOR_CONSUMER_GROUP_ID:-ingestion_executor}
 source:
   type: "kafka"
   config:

diff --git a/docker/config/slack_action.yaml b/docker/config/slack_action.yaml
@@ -11,7 +11,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-name: datahub_slack_action
+name: ${DATAHUB_ACTIONS_SLACK_CONSUMER_GROUP_ID:-datahub_slack_action}
 enabled: ${DATAHUB_ACTIONS_SLACK_ENABLED:-false}
 source:
   type: "kafka"

diff --git a/docker/config/teams_action.yaml b/docker/config/teams_action.yaml
@@ -11,7 +11,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-name: datahub_teams_action
+name: ${DATAHUB_ACTIONS_TEAMS_CONSUMER_GROUP_ID:-datahub_teams_action}
 enabled: ${DATAHUB_ACTIONS_TEAMS_ENABLED:-false}
 source:
   type: "kafka"