diff options
| author |   liamfallon <liam.fallon@est.tech> | 2019-07-05 13:41:03 +0000 |
|---|---|---|
| committer | liamfallon <liam.fallon@est.tech> | 2019-07-05 13:41:03 +0000 |
| commit | cad7cff7dc945eefaf27815742461d6db6ab8eac (patch) | |
| tree | 4f3e6b26fadd9fff47deccfe2cbff0e76a46e948 /testsuites/integration/integration-common | |
| parent | 9f0678f3ab333949076b5b9747158cf40e08fbef (diff) | |
Add duplicate check, examples for kafka Properties
Added checks for dealing with duplication of specification of properties
explicitly and in kafkaPropertes
Added examples for kafkaProperties
Added documentation for kafkaProperties
Issue-ID: POLICY-1818
Change-Id: Icbe01d6f1d25d4570dcc85cc3db28588743b9c41
Signed-off-by: liamfallon <liam.fallon@est.tech>
Diffstat (limited to 'testsuites/integration/integration-common')
| -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": { |