4.2 Kafka Topic增加前缀

关于此功能

此功能用于定义DataPipeline在Kafka中创建的Topic的前缀。

操作步骤

  1. 停止所有容器;

  2. 修改部署脚本,在Kafka中添加或修改如下环境变量

    • 第三方组件topic,暂不支持修改的

      __confluent.support.metrics __consumer_offsets

    • 环境变量修改

      • schema_registry - SCHEMA_REGISTRY_KAFKASTORE_TOPIC=rap-rdpl-UATCLS01-_schemas

      • dp-thrall-webservice - DP_TOPIC_NAME_PREFIX=rap-rdpl-UATCLS01-

      • source - DP_TOPIC_NAME_PREFIX=rap-rdpl-UATCLS01- - CONNECT_CONFIG_STORAGE_TOPIC=rap-rdpl-UATCLS01-config_connect_source_dp - CONNECT_OFFSET_STORAGE_TOPIC=rap-rdpl-UATCLS01-offset_connect_source_dp - CONNECT_STATUS_STORAGE_TOPIC=rap-rdpl-UATCLS01-status_connect_source_dp sink - CONNECT_CONFIG_STORAGE_TOPIC=rap-rdpl-UATCLS01-config_connect_sink_dp - CONNECT_OFFSET_STORAGE_TOPIC=rap-rdpl-UATCLS01-offset_connect_sink_dp - CONNECT_STATUS_STORAGE_TOPIC=rap-rdpl-UATCLS01-status_connect_sink_dp -DP_TOPIC_NAME_PREFIX=rap-rdpl-UATCLS01- manager - DP_TOPIC_NAME_PREFIX=rap-rdpl-UATCLS01-

  3. 按顺序启动容器

circle-info

rap-rdpl-为自定义的前缀。字符长度限制为25,只允许有大小写字母、数字、下划线、横杠

最后更新于

这有帮助吗?