KafkaProducerConfig
data class KafkaProducerConfig<K, V>(val applicationId: String = requiredConfigForKey("NAIS_APP_NAME"), val brokers: String = requiredConfigForKey("KAFKA_BROKERS"), val ssl: SslConfig? = SslConfig(), val schemaRegistry: SchemaRegistryConfig? = SchemaRegistryConfig(), val additionalProperties: Properties = Properties())(source)
Constructors
Link copied to clipboard
constructor(applicationId: String = requiredConfigForKey("NAIS_APP_NAME"), brokers: String = requiredConfigForKey("KAFKA_BROKERS"), ssl: SslConfig? = SslConfig(), schemaRegistry: SchemaRegistryConfig? = SchemaRegistryConfig(), additionalProperties: Properties = Properties())