application-test.yml
2.16 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
spring:
datasource:
jndi-name: jdbc/iclconnectDS
profiles:
#系统环境
env: test
#============== kafka ===================
kafka:
# 指定kafka server的地址,集群配多个,中间,逗号隔开
bootstrap-servers: 47.103.140.98:9092
#验证文件地址
iclear-kerberos-jaasPath: /opt/fedex/iclconnect/conf/app_3537251_iclear_jaas.conf
iclear-kerberos-krb5: /opt/fedex/iclconnect/conf/krb5.conf
#=============== provider =======================
producer:
#可以设置的值为:all, -1, 0, 1
acks: -1
# 当retris为0时,produce不会重复。retirs重发,此时repli节点完全成为leader节点,不会产生消息丢失。
retries: 3
# 每次批量发送消息的数量,produce积累到一定数据,一次发送
batch-size: 323840
properties:
linger:
# 如果kafka迟迟不发送消息(这里指的是消息没堆积到指定数量),那么过了这个时间(单位:毫秒)开始发送
ms: 10
max:
block:
# 控制block的时长,当buffer空间不够或者metadata丢失时产生block
ms: 3000
# produce积累数据一次发送,缓存大小达到buffer.memory就发送数据
buffer-memory: 33554432
#=============== consumer =======================
consumer:
#topic-name
topic-name: fdx.apac.cn.shipment.import.cdm.iclear
# 指定默认消费者group id --> 由于在kafka中,同一组中的consumer不会读取到同一个消息,依靠groud.id设置组名
group-id: imp-exp-iclconnect-test
# smallest和largest才有效,如果smallest重新0开始读取,如果是largest从logfile的offset读取。一般情况下我们都是设置smallest
auto-offset-reset: earliest
# enable.auto.commit:true --> 设置自动提交offset
enable-auto-commit: false
#如果'enable.auto.commit'为true,则消费者偏移自动提交给Kafka的频率(以毫秒为单位),默认值为5000。
auto-commit-interval: 1000
#每次kafka消费量
max-poll-records: 1000
#kafka消费线程数
spring-kafka-threadNum: 10