Source (kafka) report:
{'failures': {},
 'filtered': ['__transaction_state',
              '_confluent-telemetry-metrics',
              '_confluent_balancer_partition_samples',
              '_confluent-metrics',
              '_confluent_balancer_api_state',
              '__consumer_offsets',
              '_confluent_balancer_broker_samples',
              '_confluent-license'],
 'topics_scanned': 21,
 'warnings': {'topic1': ['failed to get value schema: Subject not found. (HTTP status code 404, SR code 40401)'],
              'topic2': ['failed to get value schema: Subject not found. (HTTP status code 404, SR code 40401)'],
              'topic3': ['failed to get value schema: Subject not found. (HTTP status code 404, SR code 40401)']},
 'workunit_ids': ['kafka-topic1',
                  'kafka-topic2',
                  'kafka-topic3',
                  ],
 'workunits_produced': 13}
Sink (datahub-kafka) report:
{'downstream_end_time': None,
 'downstream_start_time': None,
 'downstream_total_latency_in_seconds': None,
 'failures': [],
 'records_written': 13,
 'warnings': []}