This commit is contained in:
zren25
2025-03-31 22:27:12 +08:00
parent c942396026
commit de204af6b0

View File

@@ -17,7 +17,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.listener.ConsumerSeekAware;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PostMapping;
@@ -42,7 +41,7 @@ import java.util.concurrent.Executors;
@Component
@RestController
@RefreshScope
public class CorpusProcessKafkaProducer implements ConsumerSeekAware {
public class CorpusProcessKafkaProducer {
@Autowired
private TmTelephoneCorpusService tmTelephoneCorpusService;