Package org.smallmind.bayeux.oumuamua.server.spi.backbone.kafka

Class KafkaConnector

java.lang.Object

org.smallmind.bayeux.oumuamua.server.spi.backbone.kafka.KafkaConnector

public class KafkaConnector
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaConnector(KafkaServer... servers)

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.consumer.Consumer<Long,byte[]>	createConsumer(String clientId, String groupId, String... topics)
org.apache.kafka.clients.producer.Producer<Long,byte[]>	createProducer(String clientId)
String	getBoostrapServers()
<R> R	invokeAdminClient(Function<org.apache.kafka.clients.admin.AdminClient,R> clientFunction)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)