wuxw
2022-07-19 05683f2b2bdbdbe21cf17ad523c21ab338bd1c54
service-job/src/main/java/com/java110/job/kafka/JobServiceKafka.java
@@ -25,7 +25,7 @@
import com.java110.utils.util.BeanConvertUtil;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
@@ -105,8 +105,6 @@
        String extCommunityId = header.getString("extCommunityId");
        //签名校验
        CommunityDto community = null;
        try {
            //获得小区对象
            String secure = getExtCommunityCode(extCommunityId);