I tried running the example on another topic with single partition and
single replica and same example Java Producer works
On Sat, Nov 8, 2014 at 4:25 PM, Hardik Pandya
wrote:
> Hello Champs,
>
> I am trying to run first java producer example.
>
> Upon running this example, producer successfull
Please check your consumer's position
http://kafka.apache.org/documentation.html#basic_ops_consumer_lag
2014-11-16 7:09 GMT+08:00 Stream Processing :
> anyone?
>
> On Sat, Nov 8, 2014 at 4:25 PM, Hardik Pandya
> wrote:
>
> > Hello Champs,
> >
> > I am trying to run first java producer example
anyone?
On Sat, Nov 8, 2014 at 4:25 PM, Hardik Pandya
wrote:
> Hello Champs,
>
> I am trying to run first java producer example.
>
> Upon running this example, producer successfully sends the message, at
> least it looks like it does, there is no java dump
>
> But trying to verify the messages
The producer code here looks fine. It may be an issue with the consumer, or
how the consumer is used.
If you are running the producer before starting a consumer, make sure you
get all messages by setting auto.offset.reset=smallest (in the console
consumer you can use --from-beginning)
Also, you c
Hello Champs,
I am trying to run first java producer example.
Upon running this example, producer successfully sends the message, at
least it looks like it does, there is no java dump
But trying to verify the messages on consumer side - it does not return any
data sent by producer
https://cwi
