[
https://issues.apache.org/jira/browse/APEXMALHAR-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093375#comment-15093375
]
ASF GitHub Bot commented on APEXMALHAR-1970:
--------------------------------------------
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/167#discussion_r49418985
--- Diff:
kafka/src/test/java/org/apache/apex/malhar/kafka/KafkaInputOperatorTest.java ---
@@ -48,26 +48,30 @@
private int totalBrokers = 0;
+ private String partition = null;
-
- @Parameterized.Parameters(name = "multi-cluster: {0}, multi-partition:
{1}")
- public static Collection<Boolean[]> testScenario()
+ @Parameterized.Parameters(name = "multi-cluster: {0}, multi-partition:
{1}, partition: {2}")
+ public static Collection<Object[]> testScenario()
{
- return Arrays.asList(new Boolean[][]{{true, false}, // multi cluster
with single partition
- {true, true}, // multi cluster with multi partitions
- {false, true}, // single cluster with multi partitions
- {false, false}, // single cluster with single partitions
+ return Arrays.asList(new Object[][]{{true, false, "one_to_one"},//
multi cluster with single partition
--- End diff --
Add different partition strategy settings
> ArrayOutOfBoundary error in One_To_Many Partitioner for 0.9 kafka input
> operator
> --------------------------------------------------------------------------------
>
> Key: APEXMALHAR-1970
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-1970
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Siyuan Hua
> Assignee: Siyuan Hua
> Fix For: 3.4.0
>
>
> Should have the same support as found in the 0.8.x implementation.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
