package javadsl
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- abstract class BaseKafkaTest extends KafkaTestKitClass
- Annotations
- @SuppressWarnings()
- abstract class KafkaJunit4Test extends BaseKafkaTest
JUnit 4 base-class with some convenience for accessing a Kafka broker.
JUnit 4 base-class with some convenience for accessing a Kafka broker.
- Annotations
- @SuppressWarnings()
Value Members
- object ConsumerControlFactory
Helper factory to create pekko.kafka.javadsl.Consumer.Control instances when testing without a Kafka broker.
Helper factory to create pekko.kafka.javadsl.Consumer.Control instances when testing without a Kafka broker.
- Annotations
- @ApiMayChange()