File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1210,7 +1210,8 @@ def verify_avro_explicit_read_schema():
1210
1210
conf = {'bootstrap.servers' : bootstrap_servers ,
1211
1211
'error_cb' : error_cb ,
1212
1212
'api.version.request' : api_version_request ,
1213
- 'default.topic.config' : {'produce.offset.report' : True }}
1213
+ 'produce.offset.report' : True
1214
+ }
1214
1215
1215
1216
# Create producer
1216
1217
if schema_registry_url :
@@ -1247,9 +1248,8 @@ def verify_avro_explicit_read_schema():
1247
1248
'api.version.request' : api_version_request ,
1248
1249
'on_commit' : print_commit_result ,
1249
1250
'error_cb' : error_cb ,
1250
- 'default.topic.config' : {
1251
- 'auto.offset.reset' : 'earliest'
1252
- }}
1251
+ 'auto.offset.reset' : 'earliest'
1252
+ }
1253
1253
1254
1254
for i , combo in enumerate (combinations ):
1255
1255
reader_key_schema = combo .pop ("reader_key_schema" )
You can’t perform that action at this time.
0 commit comments