little-megabyte-1074
gentle-camera-33498
06/28/2022, 3:37 AMlemon-hydrogen-83671
06/28/2022, 4:29 PM...
'workunits_produced': 2121}
Sink (datahub-kafka) report:
{'downstream_end_time': None,
'downstream_start_time': None,
'downstream_total_latency_in_seconds': None,
'failures': [],
'records_written': 2359,
'warnings': []}
I know from experience that querying for the list of kafka topics is relatively quick (you can test it using console-sink
) which makes me think that we are possible publishing these mcp individually as opposed to a micro batch which could hurt performance.
The main concern is that this is for a single recipe so as we get into the 10s of recipes ingestion runs could take hours.lemon-hydrogen-83671
06/28/2022, 4:30 PMlittle-megabyte-1074
lemon-hydrogen-83671
07/05/2022, 6:23 PMlittle-megabyte-1074
gentle-camera-33498
07/05/2022, 6:32 PM