server: port: 9995 spring: kafka: bootstrap-servers: kafka.server:29092 # bootstrap-servers: 10.112.89.239:9092 #bootstrap-servers: localhost:9092 producer: # 发生错误后,消息重发的次数。 retries: 0 #当有多个消息需要被发送到同一个分区时,生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小,按照字节数计算。 batch-size: 16384 # 设置生产者内存缓冲区的大小。 buffer-memory: 33554432 # 键的序列化方式 key-serializer: org.apache.kafka.common.serialization.StringSerializer # 值的序列化方式 value-serializer: org.apache.kafka.common.serialization.StringSerializer # acks=0 : 生产者在成功写入消息之前不会等待任何来自服务器的响应。 # acks=1 : 只要集群的首领节点收到消息,生产者就会收到一个来自服务器成功响应。 # acks=all :只有当所有参与复制的节点全部收到消息时,生产者才会收到一个来自服务器的成功响应。 acks: 1 listener: # 在侦听器容器中运行的线程数。 concurrency: 5 #listner负责ack,每调用一次,就立即commit ack-mode: manual_immediate missing-topics-fatal: false redis: host: 127.0.0.1 port: 6379 database: 1 timeout: 10s rabbitmq: host: 10.110.33.6 port: 6005 username: root password: kHkeRBIC taiji: ak1: AK3aa44d2fc93e44bfb1089a9693a9091f #打私办 sk1: SK608e9dd1360649658868199bda4611e8 api1: DZZW_DSB_JDJK_QQCS_DSSJ ak2: AK6fabf1afe47e4b7baf4083469a95c839 #国家邮政局 寄件 sk2: SK17a6deeeadb34ef196387e73f5445934 api2: gjyzj_kdjjcxjk ak3: AK4520bf99ded14ac2822bdce75b09926e sk3: SKa2c7159bfbbc4d41a7f858e6892ac6e5 api3: gjyzj_kdjjcxjgjk topic: hnsgYzKuaiDi ak4: AK8fa51d33d1f941beaba15ef146185186 #国家邮政局_快递收件查询接口(协查函) sk4: SK6ca16b0b8cf54fba8208410a598fcd1d api4: gjyzj_kdsjcxjk ak5: AK1a2073a397034645a830cacd395549bc #国家邮政局_快递收件查询结果接口(结果反馈) sk5: SKd1aebd2feb2b407dbd86afc711e80db5 api5: gjyzj_kdsjcxjgjk island: person: ak: AKf28efa2a520349c9b4fd4395fabdd5bd sk: SK7db59facce1c4cf8af767d1e93c83881 api: DZZW_JCDRYTJXX_SGPT appname: query200 flight: ak: AK0cc95b0affe443d79d32b9c0a96dd301 sk: SKc5dbd890c3df448f90f7b79dfed6d4c1 api: DZZW_RKJJCDHBTJXX_SGPT appname: query201