How to use multiple search methods to retrieve data in ElasticSearch
How to resolve the loss and consumption of Kafka messages exactly one-time
Flink kafka producer with transaction support
BackgroundIn flink 1.5 above, it provides a new kafka producer implementation: FlinkKafkaProducer011

