For multi-stream ingestion, there was a bug in KafkaConsumerFactory (using partitionGroupId instead of streamPartitionGroupId).
I'm assuming the fix in
PR #15094 isn't in 1.3.0 since it's missing from the release tag and was opened after the Feb 17 release date.
Should we explicitly mention in the 1.3.0 release doc that Kafka multi-topic ingestion is broken in this version? Let me know if I'm missing something