kafka-neo4j/src/main/resources/application-prd.properties

#eureka.client.serviceUrl.defaultZone= http://192.168.1.1:8900/eureka/

#Neo4j配置(第一台机器)
spring.data.neo4j.username.v1=neo4j
spring.data.neo4j.password.v1=neo4j168
spring.data.neo4j.uri.v1=bolt://192.168.2.57:7687

#Neo4j配置(第二台机器)
spring.data.neo4j.username.v2=neo4j
spring.data.neo4j.password.v2=neo4j168
spring.data.neo4j.uri.v2=bolt://192.168.2.60:7687


#spring.datasource.url = jdbc:mysql://rm-uf61r3m23ba1p5z3dfo.mysql.rds.aliyuncs.com:3306/prism1?useUnicode=true&characterEncoding=utf-8

#内网地址
spring.datasource.url = jdbc:mysql://rm-uf61r3m23ba1p5z3d.mysql.rds.aliyuncs.com:3306/prism1?useUnicode=true&characterEncoding=utf-8
spring.datasource.username = wenshu
spring.datasource.password = wenshu_168
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

scheduling.enabled = true


#============== kafka ===================
# 指定kafka 代理地址,可以多个

#dev
#spring.kafka.bootstrap-servers=106.14.211.187:9092
#老版本kafka
#spring.kafka.bootstrap-servers=192.168.4.237:9092,192.168.4.235:9092,192.168.4.236:9092
#prod
spring.kafka.bootstrap-servers=192.168.4.239:9092,192.168.4.241:9092,192.168.4.240:9092


#topic
spring.kafka.topic_node_relation_union=inc_node_relation_union
spring.kafka.topic_person_companys=inc_person_companys
spring.kafka.topic_person_merge=inc_person_merge
spring.kafka.topic_case=inc_judicial_case_union
spring.kafka.topic_person_merge_v2=inc_person_merge_v2
#=============== provider  =======================
spring.kafka.producer.retries=3
# 每次批量发送消息的数量
spring.kafka.producer.batch-size=16384
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

#=============== consumer  =======================
# 指定默认消费者group id
spring.kafka.consumer.group-id=neo4j_node_relation

spring.kafka.consumer.auto-offset-reset=earliest
# 取消自动提交
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
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
# 手动提交
#spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE

#mongo
#spring.data.mongodb.uri=mongodb://itslaw:itslaw_168@dds-uf6ff5dfd9aef3641601-pub.mongodb.rds.aliyuncs.com:3717,dds-uf6ff5dfd9aef3642555-pub.mongodb.rds.aliyuncs.com:3717/itslaw?replicaSet=mgset-6501997&maxIdleTimeMS=3000
spring.data.mongodb.uri=mongodb://itslaw:itslaw_168@dds-uf6ff5dfd9aef3641.mongodb.rds.aliyuncs.com:3717,dds-uf6ff5dfd9aef3642.mongodb.rds.aliyuncs.com:3717/itslaw?replicaSet=mgset-6501997