pmackles

package example.hbase.tools;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.NavigableMap;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.HBaseConfiguration;

pmackles

import java.util.Properties;

import kafka.javaapi.producer.Producer;
import kafka.javaapi.producer.ProducerData;
import kafka.producer.ProducerConfig;

public class DCSProducer {

        public static void main(String args[]) {
                Properties props = new Properties();

pmackles

2012-11-15 23:14:42
Full thread dump Java HotSpot(TM) 64-Bit Server VM (20.4-b02 mixed mode):

"DestroyJavaVM" prio=10 tid=0x00002aaab81b1800 nid=0x7a41 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"ProducerSendThread--2137970308" prio=10 tid=0x00002aaab80df800 nid=0x7a52 waiting on condition [0x0000000041038000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000087e19310> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)

pmackles

import java.util.Properties;

import kafka.javaapi.producer.Producer;
import kafka.javaapi.producer.ProducerData;
import kafka.producer.ProducerConfig;

public class DCSProducer {

	public static void main(String args[]) {
		Properties props = new Properties();