fix: Update encoding for structured event (#384)
Signed-off-by: Paul Strachan <paul.strachan@det.nsw.edu.au>
This commit is contained in:
parent
7f355d10c1
commit
0a1a03db64
|
@ -33,7 +33,7 @@ public class SampleProducer {
|
|||
|
||||
// Configure the CloudEventSerializer to emit events as json structured events
|
||||
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, CloudEventSerializer.class);
|
||||
props.put(CloudEventSerializer.ENCODING_CONFIG, Encoding.BINARY);
|
||||
props.put(CloudEventSerializer.ENCODING_CONFIG, Encoding.STRUCTURED);
|
||||
props.put(CloudEventSerializer.EVENT_FORMAT_CONFIG, JsonFormat.CONTENT_TYPE);
|
||||
|
||||
// Create the KafkaProducer
|
||||
|
|
Loading…
Reference in New Issue