Package com.onec.kafka

Class OnecKafkaProperties

java.lang.Object

com.onec.kafka.OnecKafkaProperties

@ConfigurationProperties(prefix="onec.kafka")
public class OnecKafkaProperties
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OnecKafkaProperties.Inbound	Inbound (consumer) settings.

Constructor Summary

Constructors

Constructor	Description
OnecKafkaProperties()

Method Summary

Modifier and Type	Method	Description
OnecKafkaProperties.Inbound	getInbound()
int	getRelayBatchSize()
Map<String,String>	getRemoteServices()
String	getServiceName()
String	getTopic()
boolean	isEnabled()
void	setEnabled(boolean enabled)
void	setInbound(OnecKafkaProperties.Inbound inbound)
void	setRelayBatchSize(int relayBatchSize)
void	setRemoteServices(Map<String,String> remoteServices)
void	setServiceName(String serviceName)
void	setTopic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Details

OnecKafkaProperties

public OnecKafkaProperties()

Method Details

isEnabled

public boolean isEnabled()

setEnabled

public void setEnabled(boolean enabled)

getServiceName

public String getServiceName()

setServiceName

public void setServiceName(String serviceName)

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getRelayBatchSize

public int getRelayBatchSize()

setRelayBatchSize

public void setRelayBatchSize(int relayBatchSize)

getRemoteServices

public Map<String,String> getRemoteServices()

setRemoteServices

public void setRemoteServices(Map<String,String> remoteServices)

getInbound

public OnecKafkaProperties.Inbound getInbound()

setInbound

public void setInbound(OnecKafkaProperties.Inbound inbound)