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 972cb28 commit b0edc44Copy full SHA for b0edc44
azure/functions/decorators/function_app.py
@@ -1246,7 +1246,7 @@ def kafka_trigger(self,
1246
consumer_group: Optional[str] = None,
1247
avro_schema: Optional[str] = None,
1248
key_avro_schema: Optional[str] = None,
1249
- key_data_type: Optional[Union[KafkaMessageKeyType, str]] = None,
+ key_data_type: Optional[Union[KafkaMessageKeyType, str]] = KafkaMessageKeyType.STRING,
1250
username: Optional[str] = None,
1251
password: Optional[str] = None,
1252
ssl_key_location: Optional[str] = None,
@@ -2607,7 +2607,7 @@ def kafka_output(self,
2607
broker_list: str,
2608
2609
2610
2611
2612
2613
0 commit comments