配置文件提交

amos-boot-utils/amos-boot-utils-message/src/main/resources/application-dev.properties

@@ -23,7 +23,7 @@ spring.redis.password=1234560
 
 #需要监听得kafka消息主题 根据是否是中心极和站端选择需要监听得主题进行配置
 kafka.topics=null.topic
-kafka.init.topics=akka.iot.created,akka.patrol.created,akka.sign.created,akka.bussSign.created,akka.user.created
+kafka.init.topics=
 
-#需要监听得eqm消息主题 根据是否是中心极和站端选择需要监听得主题进行配置
+#需要监听得eqm消息主题 根据是否是中心极和站端选择需要监听得主题进行配置 emq.iot.created,
 emq.topic=emq.iot.created,emq.patrol.created,emq.sign.created,emq.bussSign.created,emq.user.created
\ No newline at end of file

amos-boot-utils/amos-boot-utils-message/src/main/resources/application.properties

@@ -5,59 +5,59 @@ spring.profiles.active=dev
 spring.jackson.time-zone=GMT+8
 spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
 spring.jackson.serialization.write-dates-as-timestamps=true
-# kafka集群信息
+# kafka集群信息
 spring.kafka.bootstrap-servers=172.16.3.100:9092
-# 生产者配置
-# 设置大于0的值，则客户端会将发送失败的记录重新发送  # 重试次数
-spring.kafka.producer.retries=3
+# 生产者配置
+# 设置大于0的值，则客户端会将发送失败的记录重新发送  # 重试次数
+spring.kafka.producer.retries=0
 #16K
 spring.kafka.producer.batch-size=16384
 spring.kafka.producer.buffer-memory=33554432
-# 应答级别
-# acks=0 把消息发送到kafka就认为发送成功
-# acks=1 把消息发送到kafka leader分区，并且写入磁盘就认为发送成功
-# acks=all 把消息发送到kafka leader分区，并且leader分区的副本follower对消息进行了同步就任务发送成功
+# 应答级别
+# acks=0 把消息发送到kafka就认为发送成功
+# acks=1 把消息发送到kafka leader分区，并且写入磁盘就认为发送成功
+# acks=all 把消息发送到kafka leader分区，并且leader分区的副本follower对消息进行了同步就任务发送成功
 spring.kafka.producer.acks=1
-# 指定消息key和消息体的编解码方式
-#      # 批量处理的最大大小 单位 byte
+# 指定消息key和消息体的编解码方式
+#      # 批量处理的最大大小 单位 byte
 #      batch-size: 4096
-#      # 发送延时,当生产端积累的消息达到batch-size或接收到消息linger.ms后,生产者就会将消息提交给kafka
+#      # 发送延时,当生产端积累的消息达到batch-size或接收到消息linger.ms后,生产者就会将消息提交给kafka
 #      buffer-memory: 33554432
-#      # 客户端ID
+#      # 客户端ID
 #      client-id: hello-kafka
-#      # 消息压缩：none、lz4、gzip、snappy，默认为 none。
+#      # 消息压缩：none、lz4、gzip、snappy，默认为 none。
 #      compression-type: gzip
 
 spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
 spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
 
-# 消费者组
-# 当kafka中没有初始offset或offset超出范围时将自动重置offset
-# earliest:重置为分区中最小的offset
-# latest:重置为分区中最新的offset(消费分区中新产生的数据)
-# none:只要有一个分区不存在已提交的offset,就抛出异常
+# 消费者组
+# 当kafka中没有初始offset或offset超出范围时将自动重置offset
+# earliest:重置为分区中最小的offset
+# latest:重置为分区中最新的offset(消费分区中新产生的数据)
+# none:只要有一个分区不存在已提交的offset,就抛出异常
 spring.kafka.consumer.group-id=zhTestGroup
 spring.kafka.consumer.enable-auto-commit=false
-# 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
-#      # 自动提交的频率 单位 ms
+# 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
+#      # 自动提交的频率 单位 ms
 #      auto-commit-interval: 1000
-#      # 批量消费最大数量
+#      # 批量消费最大数量
 #      max-poll-records: 100
 spring.kafka.consumer.auto-offset-reset=earliest
 spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
 spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
-# 当每一条记录被消费者监听器（ListenerConsumer）处理之后提交
+# 当每一条记录被消费者监听器（ListenerConsumer）处理之后提交
 # RECORD
-# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后提交
+# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后提交
 # BATCH
-# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后，距离上次提交时间大于TIME时提交
+# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后，距离上次提交时间大于TIME时提交
 # TIME
-# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后，被处理record数量大于等于COUNT时提交
+# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后，被处理record数量大于等于COUNT时提交
 # COUNT
-# TIME |　COUNT　有一个条件满足时提交
+# TIME |　COUNT　有一个条件满足时提交
 # COUNT_TIME
-# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后, 手动调用Acknowledgment.acknowledge()后提交
+# 当每一批poll()的数据被消费者监听器（ListenerConsumer）处理之后, 手动调用Acknowledgment.acknowledge()后提交
 # MANUAL
-# 手动调用Acknowledgment.acknowledge()后立即提交，一般使用这种
+# 手动调用Acknowledgment.acknowledge()后立即提交，一般使用这种
 # MANUAL_IMMEDIATE
 spring.kafka.listener.ack-mode=manual_immediate

amos-boot-utils/pom.xml

@@ -20,5 +20,6 @@
         <module>amos-boot-utils-jpush</module>
         <module>amos-boot-utils-video</module>
         <module>amos-boot-utils-speech</module>
+        <module>amos-boot-utils-message</module>
     </modules>
 </project>
\ No newline at end of file