service-community/src/main/java/com/java110/community/kafka/CommunityServiceKafka.javaold mode 100644 new mode 100755
@@ -13,7 +13,7 @@ import com.java110.community.smo.ICommunityServiceSMO; 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;