问Alpakka Kafka无法定义批次
EN

Stack Overflow用户

提问于 2018-06-21 23:03:53

回答 1查看 144关注 0票数 0

// #atLeastOnceBatch
        Consumer.Control control =
            Consumer.committableSource(consumerSettings, Subscriptions.topics("topic1"))
                .mapAsync(1, msg ->
                    business(msg.record().key(), msg.record().value())
                            .thenApply(done -> msg.committableOffset())
                )
                .batch(
                    20,
                    ConsumerMessage::createCommittableOffsetBatch,
                    ConsumerMessage.CommittableOffsetBatch::updated
                )
                .mapAsync(3, c -> c.commitJavadsl())
                .to(Sink.ignore())
                .run(materializer);
        // #atLeastOnceBatch

我尝试测试Alpakka Kafka Connnector至少一次批处理示例，我得到了以下编译时错误

类型ConsumerMessage没有定义适用于此处的createCommittableOffsetBatch(ConsumerMessage.CommittableOffset)

并且类型ConsumerMessage.CommittableOffsetBatch没有定义适用于此处的更新(S，ConsumerMessage.CommittableOffset

apache-kafka

akka-stream

alpakka

回答 1

Stack Overflow用户

发布于 2018-09-28 07:06:11

这些都在0.22版本中可用。不幸的是，与Akka文档相比，Alpakka的文档有所欠缺。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/50971794

复制

相似问题

问Alpakka Kafka无法定义批次
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Alpakka Kafka无法定义批次EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Alpakka Kafka无法定义批次
EN