[
https://issues.apache.org/jira/browse/KAFKA-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15151203#comment-15151203
]
ASF GitHub Bot commented on KAFKA-2802:
---------------------------------------
GitHub user ymatsuda opened a pull request:
https://github.com/apache/kafka/pull/930
KAFKA-2802: kafka streams system tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ymatsuda/kafka streams_systest
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/930.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #930
----
commit d5c046707138db6db4535cbdfdd51ddb104b2325
Author: Yasuhiro Matsuda <yasuh...@confluent.io>
Date: 2016-02-17T01:08:58Z
system test
commit 8d035d43ebff6470bdedd6bcb459d5380dec7be3
Author: Yasuhiro Matsuda <yasuh...@confluent.io>
Date: 2016-02-17T21:02:23Z
more info in log
----
> 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)
