Java, Apache Kafka, Apache Flink, Programming, Software Development.
"org.apache.kafka.common.serialization.StringSerializer"); Producer<String, String> producer = new KafkaProducer<>(props); // Sending messages to a topic for(int i = 0; i < 100; i++){ producer.send(new ProducerRecord<String, String>("test_topic", Integer.toString(i), "value-" + i)); }