A B C D E G H I K P S W Z

A

after() - Method in class com.github.charithe.kafka.KafkaJunitRule

B

before() - Method in class com.github.charithe.kafka.KafkaJunitRule

C

call() - Method in class com.github.charithe.kafka.KafkaHelper.RecordConsumer

com.github.charithe.kafka - package com.github.charithe.kafka

consume(String, KafkaConsumer<K, V>, int) - Method in class com.github.charithe.kafka.KafkaHelper

Attempt to consume the specified number of messages

consumerConfig() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a minimal consumer configuration with auto commit enabled.

consumerConfig(boolean) - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a minimal consumer configuration.

consumerConfig() - Method in class com.github.charithe.kafka.KafkaHelper

Get the consumer configuration (with auto-commit enabled)

consumerConfig(boolean) - Method in class com.github.charithe.kafka.KafkaHelper

Get the consumer configuration

consumeStrings(String, int) - Method in class com.github.charithe.kafka.KafkaHelper

Consume specified number of string messages

create() - Static method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a new ephemeral Kafka broker with random broker port and Zookeeper port

create(int) - Static method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a new ephemeral Kafka broker with the specified broker port and random Zookeeper port

create(int, int) - Static method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a new ephemeral Kafka broker with the specified broker port and Zookeeper port

create(int, int, Properties) - Static method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a new ephemeral Kafka broker with the specified broker port, Zookeeper port and config overrides.

create() - Static method in class com.github.charithe.kafka.KafkaJunitRule

createByteConsumer() - Method in class com.github.charithe.kafka.KafkaHelper

Create a consumer that reads bytes

createByteConsumer(Properties) - Method in class com.github.charithe.kafka.KafkaHelper

Create a consumer that reads bytes

createByteProducer() - Method in class com.github.charithe.kafka.KafkaHelper

Create a producer that writes byte keys and values

createByteProducer(Properties) - Method in class com.github.charithe.kafka.KafkaHelper

Create a producer that writes byte keys and values

createConsumer(Deserializer<K>, Deserializer<V>, Properties) - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a consumer that can read from this broker

createConsumer(Deserializer<K>, Deserializer<V>, Properties) - Method in class com.github.charithe.kafka.KafkaHelper

Create a consumer that can read from this broker

createFor(EphemeralKafkaBroker) - Static method in class com.github.charithe.kafka.KafkaHelper

createProducer(Serializer<K>, Serializer<V>, Properties) - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a producer that can write to this broker

createProducer(Serializer<K>, Serializer<V>, Properties) - Method in class com.github.charithe.kafka.KafkaHelper

Create a producer that can write to this broker

createStringConsumer() - Method in class com.github.charithe.kafka.KafkaHelper

Create a consumer that reads strings

createStringConsumer(Properties) - Method in class com.github.charithe.kafka.KafkaHelper

Create a consumer that reads strings

createStringProducer() - Method in class com.github.charithe.kafka.KafkaHelper

Create a producer that writes String keys and values

createStringProducer(Properties) - Method in class com.github.charithe.kafka.KafkaHelper

Create a producer that writes String keys and values

D

dontWaitForStartup() - Method in class com.github.charithe.kafka.KafkaJunitRule

E

EphemeralKafkaBroker - Class in com.github.charithe.kafka

G

getBrokerList() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Get the current broker list string

getKafkaPort() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Get the broker port

getLogDir() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Get the path to the Kafka log directory

getZookeeperConnectString() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Get the current Zookeeper connection string

getZookeeperPort() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Get the Zookeeper port

H

helper() - Method in class com.github.charithe.kafka.KafkaJunitRule

Obtain a KafkaHelper that provides a bunch of convenience methods

I

isRunning() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Is the broker running?

K

KafkaHelper - Class in com.github.charithe.kafka

KafkaHelper.RecordConsumer<K,V> - Class in com.github.charithe.kafka

KafkaJunitRule - Class in com.github.charithe.kafka

KafkaJunitRule(EphemeralKafkaBroker) - Constructor for class com.github.charithe.kafka.KafkaJunitRule

KafkaJunitRule(EphemeralKafkaBroker, KafkaJunitRule.StartupMode) - Constructor for class com.github.charithe.kafka.KafkaJunitRule

kafkaPort() - Method in class com.github.charithe.kafka.KafkaHelper

Get the broker listener port

P

produce(String, KafkaProducer<K, V>, Map<K, V>) - Method in class com.github.charithe.kafka.KafkaHelper

Produce data to the specified topic

producerConfig() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Create a minimal producer configuration that can be used to produce to this broker

producerConfig() - Method in class com.github.charithe.kafka.KafkaHelper

Get the producer configuration

produceStrings(String, String...) - Method in class com.github.charithe.kafka.KafkaHelper

Convenience method to produce a set of strings to the specified topic

S

start() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Start the Kafka broker

stop() - Method in class com.github.charithe.kafka.EphemeralKafkaBroker

Stop the Kafka broker

W

waitForStartup() - Method in class com.github.charithe.kafka.KafkaJunitRule

Z

zookeeperConnectionString() - Method in class com.github.charithe.kafka.KafkaHelper

Get the zookeeper connection string

zookeeperPort() - Method in class com.github.charithe.kafka.KafkaHelper

Get the zookeeper port

A B C D E G H I K P S W Z