We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 59614a3 commit cda67dcCopy full SHA for cda67dc
cloudevents/kafka/conversion.py
@@ -88,7 +88,7 @@ def to_binary(
88
89
headers = {}
90
if event["datacontenttype"]:
91
- headers["datacontenttype"] = event["datacontenttype"].encode("utf-8")
+ headers["content-type"] = event["datacontenttype"].encode("utf-8")
92
for attr, value in event.get_attributes().items():
93
if attr not in ["data", "partitionkey", "datacontenttype"]:
94
if value is not None:
@@ -190,7 +190,7 @@ def to_structured(
190
191
192
if "datacontenttype" in attrs:
193
- headers["datacontenttype"] = attrs.pop("datacontenttype").encode("utf-8")
+ headers["content-type"] = attrs.pop("datacontenttype").encode("utf-8")
194
195
try:
196
value = envelope_marshaller(attrs)
0 commit comments