diff options
Diffstat (limited to 'testsuites/integration/integration-common/src')
| -rw-r--r-- | testsuites/integration/integration-common/src/main/resources/examples/config/SampleDomain/Kafka2KafkaJsonEvent.json | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/testsuites/integration/integration-common/src/main/resources/examples/config/SampleDomain/Kafka2KafkaJsonEvent.json b/testsuites/integration/integration-common/src/main/resources/examples/config/SampleDomain/Kafka2KafkaJsonEvent.json index 6b13db7d4..5f1a9c75a 100644 --- a/testsuites/integration/integration-common/src/main/resources/examples/config/SampleDomain/Kafka2KafkaJsonEvent.json +++ b/testsuites/integration/integration-common/src/main/resources/examples/config/SampleDomain/Kafka2KafkaJsonEvent.json @@ -28,7 +28,8 @@ "bufferMemory": 33554432, "producerTopic": "apex-out-json", "keySerializer": "org.apache.kafka.common.serialization.StringSerializer", - "valueSerializer": "org.apache.kafka.common.serialization.StringSerializer" + "valueSerializer": "org.apache.kafka.common.serialization.StringSerializer", + "kafkaProperties": [] } }, "eventProtocolParameters": { @@ -52,7 +53,11 @@ "apex-in-json" ], "keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", - "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer" + "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "kafkaProperties": [ + ["message.max.bytes", 1000000], + ["compression.codec", "none"] + ] } }, "eventProtocolParameters": { |