Alpakka Kafka Невозможно определить пакет

Question

// #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), который применим здесь

Answer 1

Они доступны в версии 0.22. К сожалению, в документации Alpakka не хватает немного по сравнению с Akka Docs.