修改kafka配置文件

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/impl/DeviceManageServiceImpl.java

    @Autowired
    UserDtoQuery userDtoQuery;
    @Override
    public PageInfo<Map<String, Object>> queryPageDeviceInfo(Map<String, String> params, int pageNumber, int pageSize)
            throws Exception {

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/impl/WorkEmployeeServiceImpl.java

    @Override
    public CommonResponse<PageBean<UserDto>> queryWorkEmployee(CommonRequest<UserDto> request) throws Exception {
        // TODO 组织编码
        request.getData().setOrgCode("0000");
        //request.getData().setOrgCode("0000");
        return userDtoQuery.queryWorkEmployee(request);
    }

location-rescue-service/src/main/resources/application.properties

spring.main.allow-bean-definition-overriding=true
#kafka
spring.kafka.bootstrap-servers=47.105.160.21:9090
spring.kafka.producer.retries=0
spring.kafka.producer.batch-size=16384
spring.kafka.producer.buffer-memory=33554432
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.group-id=spring-boot-demo
spring.kafka.consumer.enable-auto-commit=false
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.properties.session.timeout.ms=60000
spring.kafka.listener.log-container-config=false
spring.kafka.listener.concurrency=5
spring.kafka.listener.ack-mode=manual-immediate
kafka.bootstrap-servers=47.105.160.21:9090
kafka.topic.deviceLocation=Topic_IoT_DeviceLocation
kafka.topic.alarm=Topic_IoT_IndividualAlarm
kafka.producer.batch-size=16785
kafka.producer.retries=1
kafka.producer.buffer-memory=33554432
kafka.producer.linger=1
kafka.consumer.auto-offset-reset=latest
kafka.consumer.max-poll-records=3100
kafka.consumer.enable-auto-commit=false
kafka.consumer.auto-commit-interval=1000
kafka.consumer.session-timeout=20000
kafka.consumer.max-poll-interval=15000
kafka.consumer.max-partition-fetch-bytes=15728640
kafka.listener.batch-listener=false
kafka.listener.concurrencys=3,6
kafka.listener.poll-timeout=1500
# CACHE
#spring.cache.ehcache.config=ehcache.xml
# LOGGING
logging.level.com.ai=info
logging.level.org.springframework.data=info
logging.level.com.ai=debug
logging.level.org.springframework.data=debug
# \u5f15\u5165gis\u548ciot\u7684\u914d\u7f6e\u6587\u4ef6
spring.profiles.active=iot,gis