return KafkaTestRecord.create(key,generateEncodedPayload(i),STR0,timestamp); | return KafkaTestRecord.create(key,i.toString().getBytes(UTF_8),STR0,timestamp); | i | i.toString() | beam | d1217994ff3cf23eaed87ef157d23a1b7abd309b | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | | | Uses | True |