在Spring Boot with Kafka中,我可以如下设置ConsumerFactory的属性: @EnableKafka
@Configuration
public class KafkaConsumerConfig {
@Bean
public ConsumerFactory<String, EnrichedOrder> consumerFactory() {
Map<String, Object> props = new HashMap<>();
props.put(ConsumerConfig.BOOTSTRAP_SERVE
我使用过spring cloud data flow、rabbitmq和kafka,但我想知道是否可以使用google pub/sub安装scdf。
我不想创建一个流(新的应用程序,spring云流),它的源或宿都是gcp,我想让google pub/sub over spring cloud数据流服务器作为一个中间消息传递代理。
有什么建议吗?
我正试图通过实现Spring云功能来创建一个kafka。我使用的是spring版本2.4.0和spring版本:2020.0.0
@Slf4j
@Component
public class ArticleEventPublisher implements Function<ArticleAggregatedDocument, Message<ArticleMessage>> {
private final ArticleMessageMapper articleMessageMapper;
public ArticleEventPublisher(