Guozhang Wang created KAFKA-2802:
------------------------------------
Summary: Add integration tests for Kafka Streams
Key: KAFKA-2802
URL: https://issues.apache.org/jira/browse/KAFKA-2802
Project: Kafka
Issue Type: Sub-task
Reporter: Guozhang Wang
We want to test the following criterion:
1. Tasks are created / migrated on the right stream threads.
2. State stores are created with change-log topics in the right numbers and
assigned properly to tasks.
3. Co-partitioned topic partitions are assigned in the right way to tasks.
4. At least once processing guarantees (this include correct state store
flushing / offset committing / producer flushing behavior).
Under the following scenarios:
1. Stream process killed (both -15 and -9)
2. Broker service killed (both -15 and -9)
3. Stream process got long GC.
4. New topic added to subscribed lists.
5. New partitions added to subscribed topics.
6. New stream processes started.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
