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);