SpringCloud 訪問基礎(chǔ)的KafkaStreams對象

2023-11-29 15:38 更新

可以通過編程方式訪問spring-kafka中負(fù)責(zé)構(gòu)造KafkaStreams對象的StreamBuilderFactoryBean。每個StreamBuilderFactoryBean被注冊為stream-builder，并附加了StreamListener方法名稱。例如，如果您的StreamListener方法被命名為process，則流生成器bean被命名為stream-builder-process。由于這是工廠bean，因此在以編程方式訪問它時，應(yīng)在前面加上一個＆符號（&）進(jìn)行訪問。下面是一個示例，并假設(shè)StreamListener方法被命名為process

StreamsBuilderFactoryBean streamsBuilderFactoryBean = context.getBean("&stream-builder-process", StreamsBuilderFactoryBean.class);
			KafkaStreams kafkaStreams = streamsBuilderFactoryBean.getKafkaStreams();
以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號