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 that capable of doing this? What would be your advise?
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 <[EMAIL PROTECTED]>wrote:
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 <[EMAIL PROTECTED]>wrote:
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 fetch responses you want to test.
Hope that helps, Neha On Thu, Mar 13, 2014 at 1:40 PM, Vadim Keylis <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext