>For the integration test can we add a test where a stateful task migrates to >an instance that didn't have a stateful task on startup?
I've done a manual test by running `WordCountDemo` program in 2 instances on my machine by configuring different state directories and having only one partition for input & output topic. If you point me to an existing taskMigration test case for reference, I'm ready to add one. [ Full content available at: https://github.com/apache/kafka/pull/5696 ] This message was relayed via gitbox.apache.org for devnull@infra.apache.org
