can you post the source code for the kafka integration which you have done