不知道如果我做錯了一些事情，但我無法設法使其工作。以下是我的代碼： public class EventsApp {
private static final Logger log = LoggerFactory.getLogger(EventsApp.class);
@Value("${kafka.topic:test}")
private String top
我正在使用春季卡夫卡1.0.3消費卡夫卡消息。 2在kafka中的主題和每個主題都有1個分區。 在java代碼中，有2個@KafkaListener消費每個主題消息。 ConcurrentKafkaListenerContainerFactory的併發性設置爲1.但消息有時會延遲20多秒。 @Configuration
@EnableKafka
public class KafkaConfig
我試圖在Spring Boot應用程序中使用spring-kafka KafkaTemplate將消息寫入Kafka主題。 我創建了一個KafkaConfig類： @Configuration
@EnableKafka
public class KafkaConfig {
@Value("${kafka.broker.address}")
private String b