package kafka
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- class KafkaClient extends AnyRef
- trait KafkaSpec extends BeforeAndAfterAll with WithConfig
- case class KafkaZookeeperServer(zooKeeperServer: NIOServerCnxnFactory, kafkaServer: KafkaServer, zkAddress: String, kafkaAddress: String) extends Product with Serializable
- case class KeyMessage[K, V](k: K, msg: V, timestamp: Long) extends Product with Serializable
- class RichKafkaConsumer[K, M] extends AnyRef
Value Members
- object KafkaTestUtils
- object KafkaZookeeperServer extends Serializable