SpringCloud 訪問(wèn)基礎(chǔ)的KafkaStreams對(duì)象

2023-11-29 15:38 更新

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

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

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)