OnecKafkaProperties.Inbound (onec-framework API)

java.lang.Object

com.onec.kafka.OnecKafkaProperties.Inbound

Enclosing class:: OnecKafkaProperties

public static class OnecKafkaProperties.Inbound extends Object

Inbound (consumer) settings. Disabled by default; opt in with onec.kafka.inbound.enabled=true.

Constructor Summary

Constructors

Constructor

Description

Inbound()
Method Summary

Modifier and Type

Method

Description

String

getAutoOffsetReset()

int

getConcurrency()

String

getDeadLetterTopic()

String

getGroupId()

List<String>

getTopics()

boolean

isEnabled()

void

setAutoOffsetReset(String autoOffsetReset)

void

setConcurrency(int concurrency)

void

setDeadLetterTopic(String deadLetterTopic)

void

setEnabled(boolean enabled)

void

setGroupId(String groupId)

void

setTopics(List<String> topics)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Inbound
  
  public Inbound()
Method Details
- isEnabled
  
  public boolean isEnabled()
- setEnabled
  
  public void setEnabled(boolean enabled)
- getTopics
  
  public List<String> getTopics()
- setTopics
  
  public void setTopics(List<String> topics)
- getGroupId
  
  public String getGroupId()
- setGroupId
  
  public void setGroupId(String groupId)
- getConcurrency
  
  public int getConcurrency()
- setConcurrency
  
  public void setConcurrency(int concurrency)
- getAutoOffsetReset
  
  public String getAutoOffsetReset()
- setAutoOffsetReset
  
  public void setAutoOffsetReset(String autoOffsetReset)
- getDeadLetterTopic
  
  public String getDeadLetterTopic()
- setDeadLetterTopic
  
  public void setDeadLetterTopic(String deadLetterTopic)