diff --git a/api/turing/models/log_config.go b/api/turing/models/log_config.go index a4cb2a172..2cf5265e1 100644 --- a/api/turing/models/log_config.go +++ b/api/turing/models/log_config.go @@ -53,9 +53,9 @@ type KafkaConfig struct { // Serialization Format used for the messages SerializationFormat SerializationFormat `json:"serialization_format"` // Producer Config - Max message byte to send to broker - MaxMessageBytes int `json:"max_message_bytes"` + MaxMessageBytes int `json:"-"` // Producer Config - Compression Type of message - CompressionType string `json:"compression_type"` + CompressionType string `json:"-"` } // LogConfig contains all log configuration necessary for a deployment diff --git a/api/turing/models/log_config_test.go b/api/turing/models/log_config_test.go index 0fa670876..b26b65b64 100644 --- a/api/turing/models/log_config_test.go +++ b/api/turing/models/log_config_test.go @@ -72,9 +72,7 @@ func TestLogConfigValue(t *testing.T) { "kafka_config": { "brokers": "test-brokers", "topic": "test-topic", - "serialization_format": "test-serialization", - "max_message_bytes" : 10000, - "compression_type" : "none" + "serialization_format": "test-serialization" } }`), },