Kafka客户端不进行加密处理的代码实例

Kafka客户端不进行加密处理的代码实例

package com.kafka.safe.none;

import org.apache.kafka.clients.producer.KafkaProducer;

import org.apache.kafka.clients.producer.Producer;

import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Date;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

import java.text.SimpleDateFormat;

import java.util.*;

public class KafkaProducerTest

{

public static final String TOPIC_NAME = "bpu_sensor_router";

private static String CONTENT = "1704197100,9800100,4321,192.168.76.202,iaucap,2017-06-28 13:33:32";

public static void main(String[] args) {

String brokerList="192.168.76.202:9092";

Properties props = new Properties();

props.put("bootstrap.servers", brokerList);

props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");

props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Producer producer = new KafkaProducer(props);

Runnable runnable = new Runnable()

{

Integer times = 0;

public void run()

{

times++;

producer.send(new ProducerRecord(TOPIC_NAME,Integer.toString(times),CONTENT));

System.out.println(times);

}

};

ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();

service.scheduleAtFixedRate(runnable, 0,100,TimeUnit.MICROSECONDS);

System.out.println("-----------------");

}

}