org.springframework.kafka.test.rule

Class KafkaEmbedded

java.lang.Object

org.junit.rules.ExternalResource

org.springframework.kafka.test.rule.EmbeddedKafkaRule

org.springframework.kafka.test.rule.KafkaEmbedded

All Implemented Interfaces:

org.junit.rules.TestRule, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, KafkaRule

Deprecated.

since 2.2 in favor of EmbeddedKafkaRule

@Deprecated
public class KafkaEmbedded
extends EmbeddedKafkaRule
implements KafkaRule, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

The KafkaRule implementation for the embedded Kafka Broker and Zookeeper.

Author:

Marius Bogoevici, Artem Bilan, Gary Russell, Kamill Sokol, Elliot Kennedy, Nakul Mishra

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BEAN_NAME Deprecated.
static long	METADATA_PROPAGATION_TIMEOUT Deprecated.
static java.lang.String	SPRING_EMBEDDED_KAFKA_BROKERS Deprecated.
static java.lang.String	SPRING_EMBEDDED_ZOOKEEPER_CONNECT Deprecated.

Constructor Summary

Constructors

Constructor and Description
KafkaEmbedded(int count) Deprecated.
KafkaEmbedded(int count, boolean controlledShutdown, int partitions, java.lang.String... topics) Deprecated. Create embedded Kafka brokers listening on random ports.
KafkaEmbedded(int count, boolean controlledShutdown, java.lang.String... topics) Deprecated. Create embedded Kafka brokers.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() Deprecated.
void	bounce(BrokerAddress brokerAddress) Deprecated.
void	bounce(int index) Deprecated.
void	bounce(int index, boolean waitForPropagation) Deprecated.
KafkaEmbedded	brokerProperties(java.util.Map<java.lang.String,java.lang.String> brokerProperties) Deprecated. Specify the properties to configure Kafka Broker before start, e.g.
KafkaEmbedded	brokerProperty(java.lang.String property, java.lang.Object value) Deprecated. Specify a broker property.
void	consumeFromAllEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer) Deprecated. Subscribe a consumer to all the embedded topics.
void	consumeFromAnEmbeddedTopic(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.String topic) Deprecated. Subscribe a consumer to one of the embedded topics.
void	consumeFromEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.String... topics) Deprecated. Subscribe a consumer to one or more of the embedded topics.
java.util.Properties	createBrokerProperties(int i) Deprecated.
void	destroy() Deprecated.
void	doWithAdmin(java.util.function.Consumer<org.apache.kafka.clients.admin.AdminClient> callback) Deprecated. Create an AdminClient; invoke the callback and reliably close the admin.
BrokerAddress	getBrokerAddress(int i) Deprecated.
BrokerAddress[]	getBrokerAddresses() Deprecated.
java.lang.String	getBrokersAsString() Deprecated.
kafka.server.KafkaServer	getKafkaServer(int id) Deprecated.
java.util.List<kafka.server.KafkaServer>	getKafkaServers() Deprecated.
int	getPartitionsPerTopic() Deprecated.
java.util.Set<java.lang.String>	getTopics() Deprecated.
org.I0Itec.zkclient.ZkClient	getZkClient() Deprecated.
kafka.zk.EmbeddedZookeeper	getZookeeper() Deprecated.
java.lang.String	getZookeeperConnectionString() Deprecated.
boolean	isEmbedded() Deprecated.
void	restart(int index) Deprecated.
void	setKafkaPorts(int... kafkaPorts) Deprecated. Set explicit ports on which the kafka brokers will listen.
void	startZookeeper() Deprecated.
void	waitUntilSynced(java.lang.String topic, int brokerId) Deprecated.

Methods inherited from class org.springframework.kafka.test.rule.EmbeddedKafkaRule

after, before, getEmbeddedKafka, kafkaPorts

Methods inherited from class org.junit.rules.ExternalResource

apply

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.junit.rules.TestRule

apply

Field Detail

BEAN_NAME

public static final java.lang.String BEAN_NAME

Deprecated.

See Also:

Constant Field Values

SPRING_EMBEDDED_KAFKA_BROKERS

public static final java.lang.String SPRING_EMBEDDED_KAFKA_BROKERS

Deprecated.

See Also:

Constant Field Values

SPRING_EMBEDDED_ZOOKEEPER_CONNECT

public static final java.lang.String SPRING_EMBEDDED_ZOOKEEPER_CONNECT

Deprecated.

See Also:

Constant Field Values

METADATA_PROPAGATION_TIMEOUT

public static final long METADATA_PROPAGATION_TIMEOUT

Deprecated.

See Also:

Constant Field Values

Constructor Detail

KafkaEmbedded

public KafkaEmbedded(int count)

Deprecated.

KafkaEmbedded

public KafkaEmbedded(int count,
                     boolean controlledShutdown,
                     java.lang.String... topics)

Deprecated.

Create embedded Kafka brokers.

Parameters:

count - the number of brokers.

controlledShutdown - passed into TestUtils.createBrokerConfig.

topics - the topics to create (2 partitions per).

KafkaEmbedded

public KafkaEmbedded(int count,
                     boolean controlledShutdown,
                     int partitions,
                     java.lang.String... topics)

Deprecated.

Create embedded Kafka brokers listening on random ports.

Parameters:

count - the number of brokers.

controlledShutdown - passed into TestUtils.createBrokerConfig.

partitions - partitions per topic.

topics - the topics to create.

Method Detail

brokerProperties

public KafkaEmbedded brokerProperties(java.util.Map<java.lang.String,java.lang.String> brokerProperties)

Deprecated.

Specify the properties to configure Kafka Broker before start, e.g. auto.create.topics.enable, transaction.state.log.replication.factor etc.

Overrides:

brokerProperties in class EmbeddedKafkaRule

Parameters:

brokerProperties - the properties to use for configuring Kafka Broker(s).

Returns:

this for chaining configuration

See Also:

KafkaConfig

brokerProperty

public KafkaEmbedded brokerProperty(java.lang.String property,
                                    java.lang.Object value)

Deprecated.

Specify a broker property.

Overrides:

brokerProperty in class EmbeddedKafkaRule

Parameters:

property - the property name.

value - the value.

Returns:

the KafkaEmbedded.

Since:

2.1.4

setKafkaPorts

public void setKafkaPorts(int... kafkaPorts)

Deprecated.

Set explicit ports on which the kafka brokers will listen. Useful when running an embedded broker that you want to access from other processes.

Parameters:

kafkaPorts - the ports.

Since:

1.3

afterPropertiesSet

public void afterPropertiesSet()

Deprecated.

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

doWithAdmin

public void doWithAdmin(java.util.function.Consumer<org.apache.kafka.clients.admin.AdminClient> callback)

Deprecated.

Create an AdminClient; invoke the callback and reliably close the admin.

Parameters:

callback - the callback.

Since:

2.1.6

createBrokerProperties

public java.util.Properties createBrokerProperties(int i)

Deprecated.

destroy

public void destroy()

Deprecated.

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

getTopics

public java.util.Set<java.lang.String> getTopics()

Deprecated.

getKafkaServers

public java.util.List<kafka.server.KafkaServer> getKafkaServers()

Deprecated.

Specified by:

getKafkaServers in interface KafkaRule

getKafkaServer

public kafka.server.KafkaServer getKafkaServer(int id)

Deprecated.

getZookeeper

public kafka.zk.EmbeddedZookeeper getZookeeper()

Deprecated.

getZkClient

public org.I0Itec.zkclient.ZkClient getZkClient()

Deprecated.

Specified by:

getZkClient in interface KafkaRule

getZookeeperConnectionString

public java.lang.String getZookeeperConnectionString()

Deprecated.

Specified by:

getZookeeperConnectionString in interface KafkaRule

getBrokerAddress

public BrokerAddress getBrokerAddress(int i)

Deprecated.

getBrokerAddresses

public BrokerAddress[] getBrokerAddresses()

Deprecated.

Specified by:

getBrokerAddresses in interface KafkaRule

getPartitionsPerTopic

public int getPartitionsPerTopic()

Deprecated.

Specified by:

getPartitionsPerTopic in interface KafkaRule

bounce

public void bounce(BrokerAddress brokerAddress)

Deprecated.

startZookeeper

public void startZookeeper()

Deprecated.

bounce

@Deprecated
public void bounce(int index,
                               boolean waitForPropagation)

Deprecated.

bounce

@Deprecated
public void bounce(int index)

Deprecated.

restart

public void restart(int index)
             throws java.lang.Exception

Deprecated.

Throws:

java.lang.Exception

waitUntilSynced

@Deprecated
public void waitUntilSynced(java.lang.String topic,
                                        int brokerId)

Deprecated.

getBrokersAsString

public java.lang.String getBrokersAsString()

Deprecated.

Specified by:

getBrokersAsString in interface KafkaRule

isEmbedded

public boolean isEmbedded()

Deprecated.

Specified by:

isEmbedded in interface KafkaRule

consumeFromAllEmbeddedTopics

public void consumeFromAllEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)

Deprecated.

Subscribe a consumer to all the embedded topics.

Parameters:

consumer - the consumer.

consumeFromAnEmbeddedTopic

public void consumeFromAnEmbeddedTopic(org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
                                       java.lang.String topic)

Deprecated.

Subscribe a consumer to one of the embedded topics.

Parameters:

consumer - the consumer.

topic - the topic.

consumeFromEmbeddedTopics

public void consumeFromEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
                                      java.lang.String... topics)

Deprecated.

Subscribe a consumer to one or more of the embedded topics.

Parameters:

consumer - the consumer.

topics - the topics.