Thanks, Jay. Now it works, but instead of 1.6 I put 1.8. Unfortunatelly now I have a new error. The compiler says: [ERROR] /root/Documents/MavenExamples/abud/src/main/java/com/tecnisys/App.java:[25,2] error: cannot find symbol The code is: package com.tecnisys;
import java.util.*; public class App
{
public static void main( String[] args )
{ System.out.println( "Hello Life!" ); Properties properties = new Properties(); properties.put("metadata.broker.list", "localhost:9092"); properties.put("bootstrap.servers","comma-seperated-list-of-brokers");
properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");// key serializer
properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer"); //value serializer
properties.put("acks","1"); //message durability -- 1 mean ack after writing to leader is success. value of "all" means ack after replication. properties.put("security.protocol","SASL_PLAINTEXT"); // Security protocol to use for communication.
properties.put("batch.size","16384");// maximum size of message
KafkaProducer<String,String> producer = new KafkaProducer<String, String>(properties);
}
}
... View more
