@@ -0,0 +1,666 @@
+package com.test.groups;%0A %0Aimport kafka.consumer.ConsumerIterator;%0Aimport kafka.consumer.KafkaStream;%0A %0Apublic class ConsumerTest implements Runnable %7B%0A    private KafkaStream m_stream;%0A    private int m_threadNumber;%0A %0A    public ConsumerTest(KafkaStream a_stream, int a_threadNumber) %7B%0A        m_threadNumber = a_threadNumber;%0A        m_stream = a_stream;%0A    %7D%0A %0A    public void run() %7B%0A        ConsumerIterator%3Cbyte%5B%5D, byte%5B%5D%3E it = m_stream.iterator();%0A        while (it.hasNext())%0A            System.out.println(%22Thread %22 + m_threadNumber + %22: %22 + new String(it.next().message()));%0A        System.out.println(%22Shutting down Thread: %22 + m_threadNumber);%0A    %7D%0A%7D%0A

Create ConsumerTest.java