@Generated public class KafkaConfig extends Object
| Constructor and Description |
|---|
KafkaConfig() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object o) |
AuthConfig |
getAuthConfig() |
BackfillSource |
getBackfillSource() |
String |
getBootstrapServers() |
Map<String,String> |
getExtraOptions() |
IngestionConfig |
getIngestionConfig() |
SchemaConfig |
getKeySchema() |
String |
getName() |
SubscriptionMode |
getSubscriptionMode() |
SchemaConfig |
getValueSchema() |
int |
hashCode() |
KafkaConfig |
setAuthConfig(AuthConfig authConfig) |
KafkaConfig |
setBackfillSource(BackfillSource backfillSource) |
KafkaConfig |
setBootstrapServers(String bootstrapServers) |
KafkaConfig |
setExtraOptions(Map<String,String> extraOptions) |
KafkaConfig |
setIngestionConfig(IngestionConfig ingestionConfig) |
KafkaConfig |
setKeySchema(SchemaConfig keySchema) |
KafkaConfig |
setName(String name) |
KafkaConfig |
setSubscriptionMode(SubscriptionMode subscriptionMode) |
KafkaConfig |
setValueSchema(SchemaConfig valueSchema) |
String |
toString() |
public KafkaConfig setAuthConfig(AuthConfig authConfig)
public AuthConfig getAuthConfig()
public KafkaConfig setBackfillSource(BackfillSource backfillSource)
public BackfillSource getBackfillSource()
public KafkaConfig setBootstrapServers(String bootstrapServers)
public String getBootstrapServers()
public KafkaConfig setExtraOptions(Map<String,String> extraOptions)
public KafkaConfig setIngestionConfig(IngestionConfig ingestionConfig)
public IngestionConfig getIngestionConfig()
public KafkaConfig setKeySchema(SchemaConfig keySchema)
public SchemaConfig getKeySchema()
public KafkaConfig setName(String name)
public String getName()
public KafkaConfig setSubscriptionMode(SubscriptionMode subscriptionMode)
public SubscriptionMode getSubscriptionMode()
public KafkaConfig setValueSchema(SchemaConfig valueSchema)
public SchemaConfig getValueSchema()
Copyright © 2026. All rights reserved.