Hey Jae,
I verified passing Java properties with the property you specified and it
seems to be working fine. However, if I pass the same properties to the
hello-samza, it fails with same error you have. I have opened a bug to track
this here:
Thanks Naveen
On Thu, Mar 19, 2015 at 4:23 PM, Naveen Somasundaram
nsomasunda...@linkedin.com.invalid wrote:
Hey Jae,
I verified passing Java properties with the property you specified
and it seems to be working fine. However, if I pass the same properties to
the hello-samza, it
There was an interesting discussion over in the kafka mailing list that
might give you more ideas Roger.
Although they don't mention anything about the number of partitions when
doing so, anyways maybe it helps.
Renato M.
[1] https://www.mail-archive.com/users@kafka.apache.org/msg11976.html
Hey there,
I used the config setting task.drop.deserialization.errors=true to drop all
invalid JSON messages. It seems to work fine, in case of an ongoing message
stream. But the system will stuck when the last message was invalid and the
queue will be empty. Upcoming messages won't be
Renato,
Thanks for the link. Some interesting suggests there as well.
On Thu, Mar 19, 2015 at 2:28 AM, Renato Marroquín Mogrovejo
renatoj.marroq...@gmail.com wrote:
There was an interesting discussion over in the kafka mailing list that
might give you more ideas Roger.
Although they don't
