kafka test code with avro.