We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7f355d1 commit 0a1a03dCopy full SHA for 0a1a03d
examples/kafka/src/main/java/io/cloudevents/examples/kafka/SampleProducer.java
@@ -33,7 +33,7 @@ public static void main(String[] args) {
33
34
// Configure the CloudEventSerializer to emit events as json structured events
35
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, CloudEventSerializer.class);
36
- props.put(CloudEventSerializer.ENCODING_CONFIG, Encoding.BINARY);
+ props.put(CloudEventSerializer.ENCODING_CONFIG, Encoding.STRUCTURED);
37
props.put(CloudEventSerializer.EVENT_FORMAT_CONFIG, JsonFormat.CONTENT_TYPE);
38
39
// Create the KafkaProducer
0 commit comments