Update kafka.py
34.74% of diff hit (target 90.00%)
View this Pull Request on Codecov
34.74% of diff hit (target 90.00%)
Annotations
Check warning on line 214 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L213-L214
Added lines #L213 - L214 were not covered by tests
Check warning on line 220 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L216-L220
Added lines #L216 - L220 were not covered by tests
Check warning on line 231 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L226-L231
Added lines #L226 - L231 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#L233
Added line #L233 was 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 420 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L419-L420
Added lines #L419 - L420 were 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#L422
Added line #L422 was 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#L425-L427
Added lines #L425 - L427 were not covered by tests
Check warning on line 430 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L430
Added line #L430 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#L432-L434
Added lines #L432 - L434 were not covered by tests
Check warning on line 438 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L436-L438
Added lines #L436 - L438 were not covered by tests
Check warning on line 440 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L440
Added line #L440 was not covered by tests
Check warning on line 444 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L442-L444
Added lines #L442 - L444 were not covered by tests
Check warning on line 446 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L446
Added line #L446 was not covered by tests
Check warning on line 450 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L448-L450
Added lines #L448 - L450 were not covered by tests
Check warning on line 454 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L452-L454
Added lines #L452 - L454 were 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#L456
Added line #L456 was not covered by tests
Check warning on line 460 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L459-L460
Added lines #L459 - L460 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#L466
Added line #L466 was 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#L473-L474
Added lines #L473 - L474 were not covered by tests
Check warning on line 477 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L476-L477
Added lines #L476 - L477 were not covered by tests
Check warning on line 479 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L479
Added line #L479 was not covered by tests
Check warning on line 481 in metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
codecov / codecov/patch
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py#L481
Added line #L481 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