public class KafkaTopicFactory
extends Object
implements com.lightbend.lagom.internal.api.broker.TopicFactory
Constructor and Description |
---|
KafkaTopicFactory(ServiceInfo serviceInfo,
akka.actor.ActorSystem system,
akka.stream.Materializer materializer,
scala.concurrent.ExecutionContext executionContext) |
Modifier and Type | Method and Description |
---|---|
<Message> Topic<Message> |
create(Descriptor.TopicCall<Message> topicCall) |
@Inject public KafkaTopicFactory(ServiceInfo serviceInfo, akka.actor.ActorSystem system, akka.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext)
public <Message> Topic<Message> create(Descriptor.TopicCall<Message> topicCall)
create
in interface com.lightbend.lagom.internal.api.broker.TopicFactory