Update kafka.py
26.99% of diff hit (target 90.00%)
View this Pull Request on Codecov
26.99% of diff hit (target 90.00%)
Annotations
Check warning on line 216 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L215-L216
Added lines #L215 - L216 were not covered by tests
Check warning on line 222 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L218-L222
Added lines #L218 - L222 were not covered by tests
Check warning on line 233 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L228-L233
Added lines #L228 - L233 were not covered by tests
Check warning on line 235 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L235
Added line #L235 was not covered by tests
Check warning on line 237 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L237
Added line #L237 was not covered by tests
Check warning on line 239 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L239
Added line #L239 was not covered by tests
Check warning on line 422 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L421-L422
Added lines #L421 - L422 were not covered by tests
Check warning on line 425 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L424-L425
Added lines #L424 - L425 were not covered by tests
Check warning on line 427 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L427
Added line #L427 was not covered by tests
Check warning on line 431 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L431
Added line #L431 was not covered by tests
Check warning on line 434 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L434
Added line #L434 was not covered by tests
Check warning on line 441 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L440-L441
Added lines #L440 - L441 were not covered by tests
Check warning on line 443 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L443
Added line #L443 was not covered by tests
Check warning on line 447 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L445-L447
Added lines #L445 - L447 were not covered by tests
Check warning on line 449 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L449
Added line #L449 was not covered by tests
Check warning on line 456 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L451-L456
Added lines #L451 - L456 were not covered by tests
Check warning on line 466 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L459-L466
Added lines #L459 - L466 were not covered by tests
Check warning on line 468 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L468
Added line #L468 was not covered by tests
Check warning on line 472 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L470-L472
Added lines #L470 - L472 were not covered by tests
Check warning on line 474 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L474
Added line #L474 was not covered by tests
Check warning on line 482 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L480-L482
Added lines #L480 - L482 were not covered by tests
Check warning on line 485 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L485
Added line #L485 was not covered by tests
Check warning on line 490 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L489-L490
Added lines #L489 - L490 were not covered by tests
Check warning on line 493 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L492-L493
Added lines #L492 - L493 were not covered by tests
Check warning on line 497 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L495-L497
Added lines #L495 - L497 were not covered by tests