Flink configura la fuente de datos de Kafka

La implementación de fuente de datos relacionada con Kafka, FlinkKafkaConsumer010, se ha preestablecido en flink. Primero echemos un vistazo a la implementación específica:

El consumidor de Kafka tiene muchas implementaciones, pero al final. todos heredan de FlinkKafkaConsumerBase. Esta clase abstracta hereda RichParallelSourceFunction. ¿Le resulta familiar? Es muy similar a la clase abstracta RichSourceFunction heredada por la fuente de datos MySQL personalizada.

Como puedes ver, aquí hay muchos constructores, podemos usarlos directamente.

Nota:

a. Aquí, el objeto de propiedades se usa directamente para establecer configuraciones relacionadas con Kafka, como corredores, zk, groupId, serialización, deserialización, etc.

b. Utilice el constructor FlinkKafkaConsumer010 para especificar el tema y la configuración de propiedades.

c. SimpleStringSchema es solo para la serialización y deserialización de datos de tipo String si el contenido del mensaje en Kafka. no String, se informará un error; mire la definición de SimpleStringSchema:

d. Imprima el mensaje obtenido directamente aquí.