[
https://issues.apache.org/jira/browse/KAFKA-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-2802.
------------------------------------------
Resolution: Fixed
Fix Version/s: 0.9.1.0
Issue resolved by pull request 930
[https://github.com/apache/kafka/pull/930]
> 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
> Assignee: Yasuhiro Matsuda
> Fix For: 0.9.1.0
>
>
> 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)
