net.bluemind.kafka.configuration

Interface IKafkaBroker

All Known Implementing Classes:

ZkKafkaContainer

public interface IKafkaBroker

Method Summary

Modifier and Type	Method and Description
default int	defaultPartitions()
java.lang.String	inspectAddress()
default java.lang.String	kafkaListener()
default int	maxReplicas()
default int	port()

Method Detail

inspectAddress

java.lang.String inspectAddress()

Returns:

kafka.devenv.blue

port

default int port()

kafkaListener

default java.lang.String kafkaListener()

Returns:

plaintext://kafka.devenv.blue:9093

defaultPartitions

default int defaultPartitions()

maxReplicas

default int maxReplicas()