|
@@ -27,18 +27,18 @@ spring:
|
|
|
- alikafka-pre-cn-36z3tuo9f003-1-vpc.alikafka.aliyuncs.com:9092
|
|
|
- alikafka-pre-cn-36z3tuo9f003-2-vpc.alikafka.aliyuncs.com:9092
|
|
|
- alikafka-pre-cn-36z3tuo9f003-3-vpc.alikafka.aliyuncs.com:9092
|
|
|
- producer:
|
|
|
- key-serializer: org.apache.kafka.common.serialization.StringSerializer
|
|
|
- value-serializer: org.apache.kafka.common.serialization.StringSerializer
|
|
|
- acks: 1
|
|
|
- consumer:
|
|
|
- group-id: default-group
|
|
|
- key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
|
|
- value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
|
|
- max-poll-records: 50
|
|
|
- listener:
|
|
|
- ack-mode: MANUAL_IMMEDIATE
|
|
|
- missing-topics-fatal: false
|
|
|
+ producer:
|
|
|
+ key-serializer: org.apache.kafka.common.serialization.StringSerializer
|
|
|
+ value-serializer: org.apache.kafka.common.serialization.StringSerializer
|
|
|
+ acks: 1
|
|
|
+ consumer:
|
|
|
+ group-id: default-group
|
|
|
+ key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
|
|
+ value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
|
|
+ max-poll-records: 50
|
|
|
+ listener:
|
|
|
+ ack-mode: MANUAL_IMMEDIATE
|
|
|
+ missing-topics-fatal: false
|
|
|
|
|
|
logging:
|
|
|
level:
|