0 votes
in Other Questions by (120 points)
pak arifin, saya mau tanya sewaktu ngecompile di HGrid247-3.1 ada error sperti dibawah ini:
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer;
^
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;
^
FlinkKafkaConsumer kafka_consumer_1 = new FlinkKafkaConsumer("ns.netips.parimeter.src.15266.csv",new SimpleStringSchema(),prop_kafka_consumer_1);
^
symbol: class FlinkKafkaConsumer
location: class CobaHgrid
FlinkKafkaConsumer kafka_consumer_1 = new FlinkKafkaConsumer("ns.netips.parimeter.src.15266.csv",new SimpleStringSchema(),prop_kafka_consumer_1);
^
symbol: class FlinkKafkaConsumer
location: class CobaHgrid
FlinkKafkaProducer kafka_producer_2 =new FlinkKafkaProducer("testkafkaHgrid",schema_kafka_producer_2,prop_kafka_producer_2);
^
symbol: class FlinkKafkaProducer
location: class CobaHgrid
FlinkKafkaProducer kafka_producer_2 =new FlinkKafkaProducer("testkafkaHgrid",schema_kafka_producer_2,prop_kafka_producer_2);
^
symbol: class FlinkKafkaProducer
location: class CobaHgrid
6 errors

1 Answer

0 votes
by (8.3k points)
Tambahkan addition library

kafka dan flinkkafka
Welcome to Labs247 Community, where you can ask questions and receive answers from other members of the community.
...