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
..@kafka.apache.org
> Cc: users@kafka.apache.org
> Subject: Re: kafka producer and client use same groupid
>
> Hi Surender,
>
> Please elaborate on your design
> Consumers don't talk to producers directly, Kafka is a brokered system,
> and Kafka sits between producers and
November 2015 18:24
To: d...@kafka.apache.org
Cc: users@kafka.apache.org
Subject: Re: kafka producer and client use same groupid
Hi Surender,
Please elaborate on your design
Consumers don't talk to producers directly, Kafka is a brokered system, and
Kafka sits between producers and consumers
Hi Surender,
Please elaborate on your design
Consumers don't talk to producers directly, Kafka is a brokered system, and
Kafka sits between producers and consumers
Also, consumers consume from partitions of a topic and producers write to
partitions in a topic
These partitions and the logical abstr