Java, Apache Kafka, Apache Flink, Programming, Software Development.
properties.setProperty("bootstrap.servers", "localhost:9092"); properties.setProperty("group.id", "test"); // Creating a data stream from Kafka DataStream<String> stream = env .addSource(new FlinkKafkaConsumer<>("test_topic", new SimpleStringSchema(), properties)); // Processing the stream