A B C K P R S Z

A

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

B

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

C

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

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

Create a consumer configuration.

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

Create a consumer configuration.

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

Create a Kafka consumer using consumerConfig()

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

Create a Kafka consumer using consumerConfig(boolean)

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

Create a Kafka producer using producerConfig()

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

Create a Kafka consumer that reads messages with String key and values.

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

Create a Kafka consumer that reads messages with String key and values.

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

Create a Kafka producer that produces messages with String keys and values

K

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

Get the kafka broker port

KafkaJunitRule - Class in com.github.charithe.kafka

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

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

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

KafkaJunitRule(int, int, Properties) - Constructor for class com.github.charithe.kafka.KafkaJunitRule

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

Get the Kafka log directory

P

pollMessages(String, int, Deserializer<K>, Deserializer<V>) - Method in class com.github.charithe.kafka.KafkaJunitRule

Poll the specified topic for messages

pollStringMessages(String, int) - Method in class com.github.charithe.kafka.KafkaJunitRule

Poll the specified topic for String key-valued messages

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

Create a producer configuration.

R

readMessages(KafkaConsumer<T, T>, String, int, int) - Method in class com.github.charithe.kafka.KafkaJunitRule

Deprecated.

Use pollMessages(String, int, Deserializer, Deserializer) instead.

This method is deprecated due to the switch to Kafka 0.9. The new API can return more than the expected number of messages unless manual offset management is performed. Since it is impossible to ensure that the passed-in KafkaConsumer has auto commit disabled, this method should not be used.

readStringMessages(String, int, int) - Method in class com.github.charithe.kafka.KafkaJunitRule

Deprecated.

Use pollStringMessages(String, int) instead

This method is deprecated because it silently creates a new consumer on each invocation -- which could lead to some mesages being read more than once. It also suffers from the problems described in the deprecation notice for readMessages(KafkaConsumer, String, int, int) as well.

S

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

Shutdown Kafka Broker before the test termination to test consumer exceptions

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

Starts the server

Z

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

Get the zookeeper connection string

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

Get the zookeeper port

A B C K P R S Z