Skip to content
Permalink
Browse files

Fix Akka deprecation

  • Loading branch information...
ennru committed Dec 10, 2018
1 parent 3ee4ca1 commit d51ceec4856bcef156c71e209286c00f984d8f93
Showing with 2 additions and 2 deletions.
  1. +2 −2 tests/src/test/java/docs/javadsl/FetchMetadataTest.java
@@ -11,7 +11,7 @@
import akka.kafka.KafkaConsumerActor;
import akka.kafka.KafkaPorts;
import akka.kafka.Metadata;
import akka.pattern.PatternsCS;
import akka.pattern.Patterns;
import java.time.Duration;
import java.util.List;
import java.util.Optional;
@@ -83,7 +83,7 @@ public void demo() throws Exception {
ActorRef consumer = system().actorOf((KafkaConsumerActor.props(settings)));

CompletionStage<Metadata.Topics> topicsStage =
PatternsCS.ask(consumer, Metadata.createListTopics(), timeout)
Patterns.ask(consumer, Metadata.createListTopics(), timeout)
.thenApply(reply -> ((Metadata.Topics) reply));

// convert response

0 comments on commit d51ceec

Please sign in to comment.
You can’t perform that action at this time.