Since Feast should support the ingestion of data from Kafka topics (in the format of KV) using KafkaIO, the FeatureRow proto should be wrapped to have FeatureRowKey (K) and FeatureRowMessage (V).