Currently generate_payload is called even for deletion events via KafkaSource. This forces implementing code to check to see if the only key is the payload key and return otherwise. We should intentionally not call generate_payload on deletion events.
Currently
generate_payloadis called even for deletion events via KafkaSource. This forces implementing code to check to see if the only key is the payload key and return otherwise. We should intentionally not callgenerate_payloadon deletion events.