Fix #5544: Downgrading Kafka Version (#5545)

This commit is contained in:
Mayur Singal 2022-06-22 01:52:04 +05:30 committed by GitHub
parent 4cb370e8a9
commit 9fbe07d2d0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -95,7 +95,7 @@ plugins: Dict[str, Set[str]] = {
"presto-types-parser==0.0.2",
},
"kafka": {
"confluent_kafka>=1.5.0",
"confluent_kafka==1.8.2",
"fastavro>=1.2.0",
"avro-python3",
"confluent_avro",