Hi! I actually fixed the issue, even though I'm still not 100% sure why it caused this:
The kafka connector got a setting called "tasks.max", which I set to a number higher than 1. After setting tasks.max=1 I can process all data I want without any issues - I assume it somehow can't use the extractor for any additional tasks. - svonn -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
