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 |
---|---|
KafkaResource |
KafkaResourceFactory.create(String kafkaVersion)
Returns a
KafkaResource instance. |
KafkaResource |
LocalStandaloneKafkaResourceFactory.create(String kafkaVersion) |
static KafkaResource |
KafkaResource.get(String version)
Returns the configured KafkaResource implementation, or a
LocalStandaloneKafkaResource if none is configured. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.