Package | Description |
---|---|
org.apache.flink.tests.util.kafka |
Modifier and Type | Class and Description |
---|---|
class |
LocalStandaloneKafkaResource
KafkaResource that downloads kafka and sets up a local kafka cluster with the bundled zookeeper. |
Modifier and Type | Method and Description |
---|---|
static KafkaResource |
KafkaResource.get(String version)
Returns the configured KafkaResource implementation, or a
LocalStandaloneKafkaResource if none is configured. |
Modifier and Type | Method and Description |
---|---|
Optional<KafkaResource> |
KafkaResourceFactory.create(String kafkaVersion)
Returns a
KafkaResource instance. |
Optional<KafkaResource> |
LocalStandaloneKafkaResourceFactory.create(String kafkaVersion) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.