_created time propagation criteria expanded.
Update kafka_connector.py Propagate _created time in produced the output based upon same source_id of input data if input data is not directly a source.
Update kafka_connector.py Propagate _created time in produced the output based upon same source_id of input data if input data is not directly a source.