EventuateKafkaConsumerConfigurationProperties (eventuate-messaging-kafka-basic-consumer 0.20.0.RELEASE API)

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumerConfigurationProperties

public class EventuateKafkaConsumerConfigurationProperties extends Object

Constructor Summary

Constructors

Constructor

Description

EventuateKafkaConsumerConfigurationProperties()

EventuateKafkaConsumerConfigurationProperties(Map<String,String> properties)
Method Summary

Modifier and Type

Method

Description

static EventuateKafkaConsumerConfigurationProperties

empty()

BackPressureConfig

getBackPressure()

long

getPollTimeout()

Map<String,String>

getProperties()

void

setBackPressure(BackPressureConfig backPressure)

void

setPollTimeout(long pollTimeout)

void

setProperties(Map<String,String> properties)

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

Constructor Details
- EventuateKafkaConsumerConfigurationProperties
  
  public EventuateKafkaConsumerConfigurationProperties()
- EventuateKafkaConsumerConfigurationProperties
  
  public EventuateKafkaConsumerConfigurationProperties(Map<String,String> properties)
Method Details
- getBackPressure
  
  public BackPressureConfig getBackPressure()
- setBackPressure
  
  public void setBackPressure(BackPressureConfig backPressure)
- getPollTimeout
  
  public long getPollTimeout()
- setPollTimeout
  
  public void setPollTimeout(long pollTimeout)
- getProperties
  
  public Map<String,String> getProperties()
- setProperties
  
  public void setProperties(Map<String,String> properties)
- empty
  
  public static EventuateKafkaConsumerConfigurationProperties empty()