wso2~自定义event-publisher

• 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
  

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

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

• 添加configmap(all-in-one/templates/am/wso2am-kafka-conf.yaml)
  

• 修改deployment(all-in-one/templates/am/wso2am-deployment.yaml)
  

• 在values.yaml中添加kafka相关配置