#use local config spring.profiles.active=simple spring.application.name=superdesk-app-services-notify server.port=8115 server.servlet.context-path=/ server.error.whitelabel.enabled=false feign.client.config.default.loggerLevel=full #mybatis mybatis.type-aliases-package=cn.superdesk.app.organisation.dao.entity mybatis.mapper-locations=classpath*:mapper/*Mapper.xml 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} # [spring kafka] spring.kafka.bootstrap-servers=172.18.223.211:9092 # 检测到topic不存在时,是否抛出异常 spring.kafka.listener.missing-topics-fatal=false spring.kafka.consumer.group-id=superdesk-app-services-notify #### kafka配置生产者 begin #### # 写入失败时,重试次数。当leader节点失效,一个repli节点会替代成为leader节点,此时可能出现写入失败, # 当retris为0时,produce不会重复。retirs重发,此时repli节点完全成为leader节点,不会产生消息丢失。 spring.kafka.producer.retries=0 # 每次批量发送消息的数量,produce积累到一定数据,一次发送 spring.kafka.producer.batch-size=16384 # produce积累数据一次发送,缓存大小达到buffer.memory就发送数据,producer可以用来缓存数据的内存大小。如果数据产生速度大于向broker发送的速度,producer会阻塞或者抛出异常,以“block.on.buffer.full”来表明。这项设置将和producer能够使用的总内存相关,但并不是一个硬性的限制,因为不是producer使用的所有内存都是用于缓存。一些额外的内存会用于压缩(如果引入压缩机制),同样还有一些用于维护请求。 spring.kafka.producer.buffer-memory=33554432 #procedure要求leader在考虑完成请求之前收到的确认数,用于控制发送记录在服务端的持久化,其值可以为如下: #acks = 0 如果设置为零,则生产者将不会等待来自服务器的任何确认,该记录将立即添加到套接字缓冲区并视为已发送。在这种情况下,无法保证服务器已收到记录,并且重试配置将不会生效(因为客户端通常不会知道任何故障),为每条记录返回的偏移量始终设置为-1。 #acks = 1 这意味着leader会将记录写入其本地日志,但无需等待所有副本服务器的完全确认即可做出回应,在这种情况下,如果leader在确认记录后立即失败,但在将数据复制到所有的副本服务器之前,则记录将会丢失。 #acks = all 这意味着leader将等待完整的同步副本集以确认记录,这保证了只要至少一个同步副本服务器仍然存活,记录就不会丢失,这是最强有力的保证,这相当于acks = -1的设置。 #可以设置的值为:all, -1, 0, 1 spring.kafka.producer.acks=1 # 指定消息key和消息体的编解码方式 spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer # sasl #spring.kafka.producer.properties.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="java_connect_kafka" password="java_connect_kafka_pwd"; #spring.kafka.producer.properties.sasl.mechanism=PLAIN #spring.kafka.producer.properties.security.protocol=SASL_PLAINTEXT # #### kafka配置生产者 end #### #### kafka配置消费者 start #### # Kafka中没有初始偏移或如果当前偏移在服务器上不再存在时,默认区最新 ,有三个选项 【latest, earliest, none】 # smallest和largest才有效,如果smallest重新0开始读取,如果是largest从logfile的offset读取。一般情况下我们都是设置smallest #spring.kafka.consumer.auto-offset-reset=earliest spring.kafka.consumer.auto-offset-reset=latest # 是否开启自动提交 # enable.auto.commit:true --> 设置自动提交offset spring.kafka.consumer.enable-auto-commit=true # 自动提交的时间间隔 如果'enable.auto.commit'为true,则消费者偏移自动提交给Kafka的频率(以毫秒为单位),默认值为5000。 spring.kafka.consumer.auto-commit-interval=1000 # 指定消息key和消息体的编解码方式 # key的解码方式 spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer # value的解码方式 spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer # [kafka topic] # KAFKA TOPIC 短信消费 superdesk.kafka.topic.fwzc.msg-test=supdesk-msg-test # 微信模板消息 superdesk.kafka.topic.notify.wxTemplateMessage=superdesk-notify-wxTemplateMessage # 小程序订阅消息 superdesk.kafka.topic.notify.wxMiniProSubscribeMessage=superdesk-notify-wxSubscribeMessage # 收款成功通知 superdesk.kafka.topic.notify.successfulCollection=superdesk-notify-successfulCollection # app消息推送 superdesk.kafka.topic.notify.appMessagePush=superdesk-notify-appMessagePush # app自定义消息(提示音)推送 superdesk.kafka.topic.notify.customAppMessagePush=superdesk-notify-customAppMessagePush info.app.name=@project.artifactId@ info.app.version=@project.version@ #spring spring.jackson.time-zone=GMT+8 spring.http.encoding.charset=UTF-8 spring.http.encoding.force=true spring.http.encoding.enabled=true server.tomcat.uri-encoding=UTF-8 auth.crypt.key=U48Y4F1AwUADW24mLVIZtih3gt9bvW0 #wei xin di zhi wx.hostUrl=https://superdesk-app-test.superdesk.cn #wei xin gong gao di zhi wx.wxAppNoticeUrl=/wx/main/?state=8#/home/@id #wei xin shen he di zhi mobile wx.wxMsgAuditUrl=/appmobile #wei xin di zhi mobile wx.wxMsgUrl=/mobile superdesk.cache.mode=standalone #superdesk.cache.groupName= superdesk.cache.servers=127.0.0.1:6379 superdesk.cache.password= superdesk.cache.database=1 superdesk.cache.maxPoolSize=10000 superdesk.cache.maxPoolIdle=10 superdesk.cache.minPoolIdle=1 superdesk.cache.maxPoolWaitMillis=10000 swagger.enable=true #datasource db.group.size=1 db.shard.size=1000 db.driverClass=com.mysql.jdbc.Driver db.initialSize=2 db.minIdle=1 db.maxActive=50 db.maxWait=60000 db.timeBetweenEvictionRunsMillis=60000 db.minEvictableIdleTimeMillis=300000 db.testOnBorrow=true db.testOnReturn=false master.db.url=jdbc:mysql://112.74.48.214:53307/super_service_new_bak?allowMultiQueries=true&autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&useSSL=false master.db.username=root master.db.password=service_newbak2019 #mybatis superdesk.mybatis.crudDriver=mapper3 #superdesk.mybatis.dbType=Mysql superdesk.mybatis.cacheEnabled=true #superdesk.mybatis.cacheEnabled=false 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 eureka.client.service-url.defaultZone=http://superdesk:superdesk2019@127.0.0.1:19991/eureka/ eureka.client.registry-fetch-interval-seconds=5 eureka.instance.lease-expiration-duration-in-seconds=30 eureka.instance.lease-renewal-interval-in-seconds=10 #hystrix hystrix.command.default.execution.timeout.enabled=true hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=10000 #ribbon ribbon.eureka.enabled=true ribbon.ServerListRefreshInterval=2000 ribbon.ConnectTimeout = 2000 ribbon.ReadTimeout = 10000 ribbon.OkToRetryOnAllOperations=false ribbon.MaxAutoRetriesNextServer=0 ribbon.MaxAutoRetries = 0 #spring spring.servlet.multipart.max-file-size=1Mb spring.servlet.multipart.max-request-size=1Mb spring.servlet.multipart.location=/tmp #loadbalancer spring.cloud.loadbalancer.retry.enabled=false #极光app?????#certificatePath 推送文件地址 certificatePath=/data/wwwroot/storage/template/floorWindow.p12 #certificatePassword certificatePassword=Huang0910 #环境 clientNo=test smsSunMei_server=http://sms-cly.cn/smsSend.do #msgOpen=on 表示开启腾讯云短信msgOpen=off 表示关闭腾讯云短??? msgOpen=on msgAppid=1400435032 msgAppkey=0f2b22a88945244c9868e7380ec0d370 msgTemplateId=773872 msgTime=15 #smsAliOpen=on 表示开启阿里短信smsAliOpen=off 表示关闭阿里短信 smsAliOpen=off smsAliAccessKeyId=LTAI5tRyGtXgWuig8NBPi2zD smsAliAccessKeySecret=glWM1hLNzehmdApqNqdNQ1qhSXgjUe smsAliTemplateCode=SMS_219605019 smsAliTemplateCodeTxt=SMS_225126568 smsAliSysDomain=dysmsapi.aliyuncs.com smsAliRegionId=cn-shenzhen #阿里推送安卓消???regionId=cn-hangzhou #accessKeyId=LTAI4G6LqSJsuRPMqKiiDJ59 #secret=1U2fE2I8N5cCGzjibR2RLnSl7QHWPD #product=mpaas #endpoint=mpaas.cn-hangzhou.aliyuncs.com #appId=ALIPUB9E0A2F6301101 #workspaceId=default #notifyType=notify #regionId=cn-hangzhou regionId=cn-hangzhou accessKeyId=LTAI5tRyGtXgWuig8NBPi2zD secret=glWM1hLNzehmdApqNqdNQ1qhSXgjUe product=mpaas endpoint=mpaas.cn-hangzhou.aliyuncs.com appId=ALIPUBE0D7E0C161013 workspaceId=default notifyType=notify #开启新推送open,不开启no newMsg=open certificatePathNew=/data/wwwroot/storage/template/new/floorWindow.p12 certificatePasswordNew=Huang0910 topic=com.ChaoJiQianTai.LYZC