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 3234e30 commit 8c52e88Copy full SHA for 8c52e88
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