How about using benthos for read/write(not sure if the support for writing is implemented yet) and publish to kafka and use ignition to read/write to/from kafka?