search

LioRoger / subscribe_example

subscribe from dts data store
63 stars 76 forks source link

请问java版是在哪里注册kafkaStore的，我没有找到，帮忙看下。 #32

Open jsonzoup opened 3 years ago

jsonzoup commented 3 years ago

请问java版是在哪里注册kafkaStore的，我没有找到，帮忙看下。

jsonzoup commented 3 years ago

//我在下面这个方法先加上了您帮忙看下行吗 private ConsumerWrap getConsumerWrap() { ConsumerWrap consumerWrap = consumerWrapFactory.getConsumerWrap(properties); // 在这儿注册kafkaStore metaStoreCenter.registerStore(KAFKA_STORE_NAME, new KafkaMetaStore(consumerWrap.getRawConsumer())); return consumerWrap; }