test codes to use kafka with avro.