fork download

copy

import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;
import org.apache.log4j.Logger;
 
import java.util.Date;
import java.util.Properties;
import java.util.Random;
 
 
/**
 * Created by nim_13512065 on 10/1/15.
 */
public class TestProducer {
    Logger logger = Logger.getLogger(TestProducer.class);
    private ProducerConfig config;
    public TestProducer() {
        Properties props = new Properties();
 
        props.put("metadata.broker.list", "localhost:9092,localhost:9093");
        props.put("serializer.class", "kafka.serializer.StringEncoder");
        props.put("partitioner.class", "SimplePartitioner");
        props.put("request.required.acks", "1");
 
        config = new ProducerConfig(props);
    }
 
    public String getIp() {
        Random rnd = new Random();
        String ip = "192.168.2." + rnd.nextInt(255);
        return ip;
    }
 
    public String getMessage(String ip) {
        long runtime = new Date().getTime();
        String msg = runtime + ",www.example.com," + ip;
        return msg;
    }
 
    public void run() {
        Producer<String, String> producer = new Producer<String, String>(config);
        String ip = getIp();
        String msg = getMessage(ip);
 
        KeyedMessage<String, String> data = new KeyedMessage<String, String>("test", msg); //ga perlu key kan?
        producer.send(data);
        producer.close();
    }
}
 

Main.java:14: error: class TestProducer is public, should be declared in a file named TestProducer.java
public class TestProducer {
       ^
Main.java:1: error: package kafka.javaapi.producer does not exist
import kafka.javaapi.producer.Producer;
                             ^
Main.java:2: error: package kafka.producer does not exist
import kafka.producer.KeyedMessage;
                     ^
Main.java:3: error: package kafka.producer does not exist
import kafka.producer.ProducerConfig;
                     ^
Main.java:4: error: package org.apache.log4j does not exist
import org.apache.log4j.Logger;
                       ^
Main.java:15: error: cannot find symbol
    Logger logger = Logger.getLogger(TestProducer.class);
    ^
  symbol:   class Logger
  location: class TestProducer
Main.java:16: error: cannot find symbol
    private ProducerConfig config;
            ^
  symbol:   class ProducerConfig
  location: class TestProducer
Main.java:15: error: cannot find symbol
    Logger logger = Logger.getLogger(TestProducer.class);
                    ^
  symbol:   variable Logger
  location: class TestProducer
Main.java:25: error: cannot find symbol
        config = new ProducerConfig(props);
                     ^
  symbol:   class ProducerConfig
  location: class TestProducer
Main.java:41: error: cannot find symbol
        Producer<String, String> producer = new Producer<String, String>(config);
        ^
  symbol:   class Producer
  location: class TestProducer
Main.java:41: error: cannot find symbol
        Producer<String, String> producer = new Producer<String, String>(config);
                                                ^
  symbol:   class Producer
  location: class TestProducer
Main.java:45: error: cannot find symbol
        KeyedMessage<String, String> data = new KeyedMessage<String, String>("test", msg); //ga perlu key kan?
        ^
  symbol:   class KeyedMessage
  location: class TestProducer
Main.java:45: error: cannot find symbol
        KeyedMessage<String, String> data = new KeyedMessage<String, String>("test", msg); //ga perlu key kan?
                                                ^
  symbol:   class KeyedMessage
  location: class TestProducer
13 errors

Standard output is empty