java.lang.Object
org.smallmind.bayeux.oumuamua.server.spi.backbone.kafka.KafkaConnector

public class KafkaConnector extends Object
  • Constructor Details

    • KafkaConnector

      public KafkaConnector(KafkaServer... servers)
  • Method Details

    • getBoostrapServers

      public String getBoostrapServers()
    • invokeAdminClient

      public <R> R invokeAdminClient(Function<org.apache.kafka.clients.admin.AdminClient,R> clientFunction)
    • createProducer

      public org.apache.kafka.clients.producer.Producer<Long,byte[]> createProducer(String clientId)
    • createConsumer

      public org.apache.kafka.clients.consumer.Consumer<Long,byte[]> createConsumer(String clientId, String groupId, String... topics)