test wechat kafka

superdesk-app-services-wechat/superdesk-app-services-wechat-test.properties

@@ -16,70 +16,15 @@ mybatis.configuration.map-underscore-to-camel-case=true
 #mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
 mybatis.configuration.log-impl=org.apache.ibatis.logging.nologging.NoLoggingImpl
 
-superdesk.configcenter.enabled=true
-superdesk.configcenter.profile=dev
-superdesk.configcenter.appName=superdesk-app-services-wechat
-superdesk.configcenter.base.url=http://config.superdesk.cn
-
-eureka.instance.preferIpAddress=true
 eureka.instance.instanceId=${spring.cloud.client.ip-address}:${spring.application.name}-1.0.0:${server.port}
 eureka.instance.metadataMap.nodeId=${client.nodeId}
 
-#schedule
-superdesk.task.groupName=${spring.application.name}
-superdesk.task.scanPackages=cn.superdesk.app.wechat.scheduler
-superdesk.task.threadPoolSize=2
-
-##kafka producer
-#superdesk.kafka.producer.defaultAsynSend=true
-#superdesk.kafka.producer.monitorEnabled=true
-#superdesk.kafka.producer.producerGroup=superdesk-app-services-wechat
-#superdesk.kafka.producer.delayRetries=0
-#kafka.producer.acks=1
-#kafka.producer.retries=1
-#
-##kafka consumer
-#superdesk.kafka.consumer.useNewAPI=true
-#superdesk.kafka.consumer.processThreads=100
-#superdesk.kafka.consumer.scanPackages=cn.superdesk.app.wechat.mq
-#kafka.consumer.group.id=wechat
-#kafka.consumer.enable.auto.commit=true
-
-
-# [superdesk kafka consumer]
-kafka.zkServers=172.18.223.206:2181
-zookeeper.servers=172.18.223.206:2181
-
-# [spring kafka]
-spring.kafka.bootstrap-servers=120.79.80.138:9092
-
-
-#spring.kafka.bootstrap-servers=39.108.55.24:9092
-#消费者的配置
-#Kafka中没有初始偏移或如果当前偏移在服务器上不再存在时,默认区最新 ，有三个选项 【latest, earliest, none】
-spring.kafka.consumer.auto-offset-reset=latest
-#是否开启自动提交
-spring.kafka.consumer.enable-auto-commit=true
-#自动提交的时间间隔
-spring.kafka.consumer.auto-commit-interval=100
-#key的解码方式
-spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
-#value的解码方式
-spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
-#消费者group id
-spring.kafka.consumer.group-id=superdesk-app-services-wechat-service
-
-
-#生产者的配置，大部分我们可以使用默认的，这里列出几个比较重要的属性
-#每批次发送消息的数量
-spring.kafka.producer.batch-size=16
-#设置大于0的值将使客户端重新发送任何数据，一旦这些数据发送失败。
-spring.kafka.producer.retries=0
-#producer可以用来缓存数据的内存大小。
-spring.kafka.producer.buffer-memory=33554432
-#key序列化方式
-spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
-spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
+# spring-kafka
+spring.kafka.bootstrap-servers=127.0.0.1:9092
+
+# topic
+# 发送微信模板消息topic
+superdesk.kafka.topic.notify.wxTemplateMessage=superdesk-notify-wxTemplateMessage
 
 #spring-boot-admin
 spring.boot.admin.client.url=http://172.18.223.211:18990
@@ -303,8 +248,6 @@ superdesk.mybatis.dynamicExpire=false
 superdesk.mybatis.cacheExpireSeconds=3600
 #superdesk.mybatis.rwRouteEnabled=false
 superdesk.mybatis.paginationEnabled=true
-mybatis.configuration.map-underscore-to-camel-case=true
-
 
 
 #eureka