Erlo

wso2~自定义event-publisher

2025-05-30 09:29:25 发布   36 浏览  
页面报错/反馈
收藏 点赞

自定义event/publishers的步骤

介绍

  • event/publishers功能位于carbon平台的event菜单,选择publishers菜单项即可打开发布者配置列表,你可以添加自定义的发布者,它们接收apim的相关事件
  • 核心组件: org.wso2.carbon.event.output.adaptor.kafka
  • 功能: 将APIM的事件数据发送到Kafka中
  • 选择的通知输入流: org.wso2.apimgt.notification.stream
  • 输出的事件适配类型: kafka
  • 消息格式: json
  • 参考:https://apim.docs.wso2.com/en/4.3.0/use-cases/streaming-tutorials/working-with-kafka

组件的依赖包

在carbon中的event/publishers中,添加一个kafka的发布者,然后配置相关kafka配置即可,它依赖下面一些jar包,需要将它们谢谢到/lib目录

  • jopt-simple-3.2.jar
  • kafka_2.10-0.8.1.jar
  • kafka-clients-0.8.2.1.jar
  • log4j-1.2.17.jar
  • metrics-annotation-2.2.0.jar
  • metrics-core-2.2.0.jar
  • org.osgi.core-6.0.0.jar
  • osgi.cmpn-6.0.0.jar
  • pax-logging-api-1.11.10.jar
  • scala-library-2.10.5.jar
  • snappy-java-1.1.2.1.jar
  • zkclient-0.11.jar
  • zookeeper-3.3.4.jar

helm对kafka-event-stream的支持

carbon/event下面的publishers以xml文件的形式被存储到文件目录/home/wso2carbon/wso2am-4.5.0/repository/deployment/server/eventpublishers下面,当你自己在carbon平台添加自定义的publisher后,由于这个目录没有挂载到磁盘,所以重启apim之后,自定义的publisher就丢失了;知道为什么会丢失,我们就可以对helm-charts进行优化了。

  1. 添加toml原内容文件(all-in-one/confs/kafka_notice.toml)


    
    
    
        {{ .Values.kafka.topic }}
        {{ .Values.kafka.host }}
    

  1. 添加configmap(all-in-one/templates/am/wso2am-kafka-conf.yaml)
{{- if .Values.kafka.enabled}}
apiVersion: v1
kind: ConfigMap
metadata:
  name: kafka-notice-conf
  namespace : {{ .Release.Namespace }}
data:
  kafka_notice.xml: {{ tpl (.Files.Get "confs/kafka_notice.toml") . | quote }}
{{- end }}
  1. 修改deployment(all-in-one/templates/am/wso2am-deployment.yaml)
{{- if .Values.kafka.enabled}}
      volumeMounts:
        - name: kafka-notice-conf
          mountPath: /home/wso2carbon/wso2am-4.5.0/repository/deployment/server/eventpublishers/kafka_notice.xml
          subPath: kafka_notice.xml
{{- end }}
    volumes:
      - name: kafka-notice-conf
        configMap:
          name: kafka-notice-conf
  1. 在values.yaml中添加kafka相关配置
kafka:
  enabled: true
  topic: apim-topic
  host: 192.168.1.17:9092

经过上面的调整,你的helm-chart已经支持了kafka的event/publisher的配置了,下次重启apim,你的kafka-event/publisher就不会丢失了

登录查看全部

参与评论

评论留言

还没有评论留言,赶紧来抢楼吧~~

手机查看

返回顶部

给这篇文章打个标签吧~

棒极了 糟糕透顶 好文章 PHP JAVA JS 小程序 Python SEO MySql 确认