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': []}