Hi,
The program given below is not running in Windows through Eclipse while its
runs in Unix platform (works fine when I run the same program in Unix where
broker is running).
Is the kafka producer not supported in windows? I am able to ping the ip
address from windows machine however. Please help.
package kpkg;
import java.util.Properties;
import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;
public class KProducer {
/**
* @param args
*/
public static void main(String[] args)
{
// TODO Auto-generated method stub
Properties props = new Properties();
//props.put("zk.connect", "10.xx.xx.xx:2181");
props.put("metadata.broker.list", "10. xx.xx.xx:9092");
//props.put("host.name", "10.87.93.57");
props.put("serializer.class", "kafka.serializer.StringEncoder");
props.put("request.required.acks", "1");
ProducerConfig config = new ProducerConfig(props);
Producer<String, String> producer = new Producer<String,
String>(config);
KeyedMessage<String, String> km = new KeyedMessage<String,
String>("SriKafkaTopic" , "SriFirstMessage");
// The message is sent to a randomly selected partition
registered in ZK
//ProducerData<String, String> data = new ProducerData<String,
String>("test-topic", "test-message");
//producer.send(data);
producer.send(km);
producer.close();
}
}
Here is the exception error that I get.
log4j:WARN No appenders could be found for logger
(kafka.utils.VerifiableProperties).
log4j:WARN Please initialize the log4j system properly.
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further
details.
Exception in thread "main" kafka.common.FailedToSendMessageException: Failed to
send messages after 3 tries.
at
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
at kafka.producer.Producer.send(Producer.scala:76)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at kpkg.KProducer.main(KProducer.java:30)
**************** CAUTION - Disclaimer *****************
This e-mail contains PRIVILEGED AND CONFIDENTIAL INFORMATION intended solely
for the use of the addressee(s). If you are not the intended recipient, please
notify the sender by e-mail and delete the original message. Further, you are
not
to copy, disclose, or distribute this e-mail or its contents to any other
person and
any such actions are unlawful. This e-mail may contain viruses. Infosys has
taken
every reasonable precaution to minimize this risk, but is not liable for any
damage
you may sustain as a result of any virus in this e-mail. You should carry out
your
own virus checks before opening the e-mail or attachment. Infosys reserves the
right to monitor and review the content of all messages sent to or from this
e-mail
address. Messages sent to or from this e-mail address may be stored on the
Infosys e-mail system.
***INFOSYS******** End of Disclaimer ********INFOSYS***
