7,540
edits
Changes
no edit summary
msg2
</pre>
==Java kliens==
<source lang=java>
Producer<Long, String> producer = null;
Properties config = new Properties();
try {
config.put("client.id", InetAddress.getLocalHost().getHostName());
config.put("bootstrap.servers", "kafka:29092");
config.put("acks", "all");
config.put(ProducerConfig.CLIENT_ID_CONFIG, "KafkaExampleProducer");
config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, LongSerializer.class.getName());
config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
producer = new KafkaProducer<Long, String>(config);
final ProducerRecord<Long, String> record = new ProducerRecord<>("adam", new Long("100"), "kkkk");
Future<RecordMetadata> future = producer.send(record);
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
if (producer != null) {
producer.flush();
producer.close();
}
}
</source>