public final class KafkaConfiguration.Initializer
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
void |
initialize(java.lang.String name,
java.lang.String hostname,
java.lang.String topicName,
java.lang.String suspenseTopicName,
int partitions,
int kafkaProducerReconnectionInterval,
int kafkaProducerReconnectionMax,
int kafkaDGWReconnectionInterval,
int kafkaDGWReconnectionMax,
int kafkaBRMReconnectionInterval,
int kafkaBRMReconnectionMax,
int kafkaHTTPReconnectionInterval,
int kafkaHTTPReconnectionMax) |
public void initialize(java.lang.String name, java.lang.String hostname, java.lang.String topicName, java.lang.String suspenseTopicName, int partitions, int kafkaProducerReconnectionInterval, int kafkaProducerReconnectionMax, int kafkaDGWReconnectionInterval, int kafkaDGWReconnectionMax, int kafkaBRMReconnectionInterval, int kafkaBRMReconnectionMax, int kafkaHTTPReconnectionInterval, int kafkaHTTPReconnectionMax)