A B C D G I K L N P R S T

A

assertAtLeastOnceForTopic(Properties, String, int, Set<Integer>, long) - Method in class com.networknt.tram.test.KafkaTestBase

We manually handle the timeout instead of using JUnit's timeout to return failure instead of timeout error.

assertExactlyOnceForTopic(Properties, String, int, List<Integer>) - Method in class com.networknt.tram.test.KafkaTestBase

assertExactlyOnceForTopic(Properties, String, int, List<Integer>, long) - Method in class com.networknt.tram.test.KafkaTestBase

We manually handle the timeout instead of using JUnit's timeout to return failure instead of timeout error.

B

brokerConnectionStrings - Static variable in class com.networknt.tram.test.KafkaTestBase

C

close() - Method in interface com.networknt.tram.test.KafkaTestEnvironment.KafkaOffsetHandler

com.networknt.tram.test - package com.networknt.tram.test

createConfig() - Static method in interface com.networknt.tram.test.KafkaTestEnvironment

createOffsetHandler() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

createOffsetHandler() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

createTestTopic(String, int, short) - Static method in class com.networknt.tram.test.KafkaTestBase

createTestTopic(String, int, short, Properties) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

createTestTopic(String, int, short) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

createTestTopic(String, int, short) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

createTestTopic(String, int, short, Properties) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

D

deleteTestTopic(String) - Static method in class com.networknt.tram.test.KafkaTestBase

deleteTestTopic(String) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

deleteTestTopic(String) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

G

getAllRecordsFromTopic(Properties, String, int, long) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getAllRecordsFromTopic(Properties, String, int, long) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getBrokerConnectionString() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getBrokerConnectionString() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getBrokerId(KafkaServer) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getBrokerId(KafkaServer) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getBrokers() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getBrokers() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getCommittedOffset(String, int) - Method in interface com.networknt.tram.test.KafkaTestEnvironment.KafkaOffsetHandler

getDefaultClientConfig() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getKafkaServer(int, File) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getKafkaServerProperties() - Method in class com.networknt.tram.test.KafkaTestEnvironment.Config

getKafkaServersNumber() - Method in class com.networknt.tram.test.KafkaTestEnvironment.Config

getLeaderToShutDown(String) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getLeaderToShutDown(String) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getSecureProperties() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getSecureProperties() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getStandardProperties() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getStandardProperties() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

getVersion() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

getVersion() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

I

isSecureMode() - Method in class com.networknt.tram.test.KafkaTestEnvironment.Config

isSecureRunSupported() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

isSecureRunSupported() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

K

KAFKA_HOST - Static variable in interface com.networknt.tram.test.KafkaTestEnvironment

kafkaServer - Static variable in class com.networknt.tram.test.KafkaTestBase

KafkaTestBase - Class in com.networknt.tram.test

The base for the Kafka tests.

KafkaTestBase() - Constructor for class com.networknt.tram.test.KafkaTestBase

KafkaTestEnvironment - Interface in com.networknt.tram.test

Abstract class providing a Kafka test environment.

KafkaTestEnvironment.Config - Class in com.networknt.tram.test

KafkaTestEnvironment.KafkaOffsetHandler - Interface in com.networknt.tram.test

Simple interface to commit and retrieve offsets.

KafkaTestEnvironmentImpl - Class in com.networknt.tram.test

An implementation of the KafkaServerProvider for Kafka 0.11 .

KafkaTestEnvironmentImpl() - Constructor for class com.networknt.tram.test.KafkaTestEnvironmentImpl

L

LOG - Static variable in class com.networknt.tram.test.KafkaTestBase

LOG - Static variable in class com.networknt.tram.test.KafkaTestEnvironmentImpl

N

NUMBER_OF_KAFKA_SERVERS - Static variable in class com.networknt.tram.test.KafkaTestBase

P

prepare() - Static method in class com.networknt.tram.test.KafkaTestBase

prepare(boolean) - Static method in class com.networknt.tram.test.KafkaTestBase

prepare(KafkaTestEnvironment.Config) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

prepare(KafkaTestEnvironment.Config) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

R

restartBroker(int) - Method in interface com.networknt.tram.test.KafkaTestEnvironment

restartBroker(int) - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

S

secureProps - Static variable in class com.networknt.tram.test.KafkaTestBase

setCommittedOffset(String, int, long) - Method in interface com.networknt.tram.test.KafkaTestEnvironment.KafkaOffsetHandler

setKafkaServerProperties(Properties) - Method in class com.networknt.tram.test.KafkaTestEnvironment.Config

setKafkaServersNumber(int) - Method in class com.networknt.tram.test.KafkaTestEnvironment.Config

setSecureMode(boolean) - Method in class com.networknt.tram.test.KafkaTestEnvironment.Config

shouldDoSomething() - Method in class com.networknt.tram.test.TramIntegrationIT

shutdown() - Method in interface com.networknt.tram.test.KafkaTestEnvironment

shutdown() - Method in class com.networknt.tram.test.KafkaTestEnvironmentImpl

shutdownClusters() - Static method in class com.networknt.tram.test.KafkaTestBase

shutDownServices() - Static method in class com.networknt.tram.test.KafkaTestBase

standardProps - Static variable in class com.networknt.tram.test.KafkaTestBase

startClusters(boolean, boolean) - Static method in class com.networknt.tram.test.KafkaTestBase

T

tempFolder - Static variable in class com.networknt.tram.test.KafkaTestBase

timeout - Static variable in class com.networknt.tram.test.KafkaTestBase

TramIntegrationIT - Class in com.networknt.tram.test

TramIntegrationIT() - Constructor for class com.networknt.tram.test.TramIntegrationIT

A B C D G I K L N P R S T