1 | initial version |
Here are the steps to write Avro data into Kafka by using Flink:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-avro</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>${kafka.version}</version>
</dependency>
Properties properties = new Properties();
properties.setProperty("bootstrap.servers", "localhost:9092");
FlinkKafkaProducer<String> kafkaProducer = new FlinkKafkaProducer<>("topic-name", new SimpleStringSchema(), properties);
toString()
method:GenericRecord record = new GenericData.Record(schema);
record.put("field1", value1);
record.put("field2", value2);
String avroString = record.toString();
DataStream<String> avroStream = env.fromElements(avroString);
avroStream.addSink(kafkaProducer);