Hi Ananth,
Could you please try to add malhar-library in test scope? Thanks!
Regards,
Siyuan
On Saturday, April 16, 2016, Ananth Gundabattula
wrote:
> Hello all,
>
> I would like to run a unit test code using the new Kafka Operator that
> supports the 0.9 version protocol.
>
> In this process,
> case I had version 3.3.1 in my packaging structure which I want in my
> runtime as well ( due to 0.9 kafka operator ) but the apex engine itself is
> a version behind ( 3.3.0 ) .. I believe malhar-versions and apex-version
> will be on different pace with respect to evolution and
Hey Ananth,
There is no OffsetManager in 0.9 kafka operator because the operator commit
the offsets(all data that has been processed by the entire application) in
kafka implicitly. The offset is supposed to be stored with consumer id, and
here the consumer id is the application name. So if you do
Hey Ananth,
Can you unzip your apa file to see if it is in the lib folder? If it is not
there, it means the packaging is not correct.
Regards,
Siyuan
On Mon, May 2, 2016 at 4:39 AM, Ananth Gundabattula wrote:
> Hello All,
>
> I was able to get around the issue pasted above by manually copying
