Configuration Reference
Version:1.1.1
Kafka Config Properties
🔗Property | Type | Description |
---|---|---|
|
org.apache.kafka.common.serialization.Deserializer |
Sets the key deserializer. |
|
org.apache.kafka.common.serialization.Deserializer |
Sets the default value deserializer. |
Property | Type | Description |
---|---|---|
|
org.apache.kafka.common.serialization.Serializer |
Sets the key serializer. |
|
org.apache.kafka.common.serialization.Serializer |
Sets the default value serializer. |
Property | Type | Description |
---|---|---|
|
java.time.Duration |
The health check timeout. Default value (10 seconds). |
Property | Type | Description |
---|---|---|
|
boolean |
Sets whether the embedded Kafka server is enabled. Default value (false). |
|
java.util.List |
The topics that should be created by the embedded instance. |
|
java.util.Properties |
Sets the broker properties. |