I see. In that case, it might be easier to write a MockSimpleConsumer and
have it return different FetchResponse objects with the error codes you
want to test. We don't have a MockSimpleConsumer as well. If you happen to
write one, you could use it with EasyMock to get the fetch() API to return
the
Neha. That is correct SimpleConsumer does not do much, but my code that is
calling it need to react properly at error response and I wanted to test
that.
On Thu, Mar 13, 2014 at 1:21 PM, Neha Narkhede wrote:
> Currently, we don't have a mock class for the server. The SimpleConsumer
> actually do
Currently, we don't have a mock class for the server. The SimpleConsumer
actually doesn't do much with the fetch request and response. Take a look
at the fetch() API on SimpleConsumer. It merely returns the response back
to the user.
Thanks,
Neha
On Wed, Mar 12, 2014 at 11:58 PM, Vadim Keylis wr
Additional information. We currently using kafka 0.8 and client will be
written in java.
On Wed, Mar 12, 2014 at 10:41 PM, Vadim Keylis wrote:
> Good evening. I am writing consumer that is based on SimpleConsumer. I
> would like to write integration/unit tests that simulate different error
> re
Good evening. I am writing consumer that is based on SimpleConsumer. I
would like to write integration/unit tests that simulate different error
responses from kafka to make sure my code handles it properly. How do you
guys advised to do this within my unit test? Do you have some kind of mock
kafka