Can u check couple of things 1. Message size that u are sending ttry sending small message 2.check which encoder defaultencoder or string encoder u are using to consume the message , are u serializing the message while sending normal stream. 3.u create.any partition of topic just create only topic no partitions On Nov 24, 2015 11:38 PM, "Kudumula, Surender" <surender.kudum...@hpe.com> wrote:
> Hi all > Is there anyway we can ensure in 0.8 that kafka remote producer and remote > consumer work on the same groupId as my java consumer cannot consume > messages from remote producer. Thanks > > > >
