[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074532#comment-17074532 ] TJ commented on BEAM-8121: -- [~aromanenko] sorry for late response. Yes issue can be closed. > Me

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1694#comment-1694 ] TJ commented on BEAM-8121: -- [~aromanenko] i've done similar kind of similar tests before with rea

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921696#comment-16921696 ] TJ commented on BEAM-8121: -- Guys, thanks for such detailed comments! I've actually tried Kafka t

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921342#comment-16921342 ] TJ commented on BEAM-8121: -- I've added cleaned code. I needed to remove ± all business logic, to

[jira] [Updated] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TJ updated BEAM-8121: - Attachment: datalake-dataflow-cleaned.zip > Messages are not distributed per machines when consuming from Kafka topic > w

[jira] [Comment Edited] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920886#comment-16920886 ] TJ edited comment on BEAM-8121 at 9/2/19 2:03 PM: -- I use Dataflow runner.

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920886#comment-16920886 ] TJ commented on BEAM-8121: -- I use Dataflow runner.  I tried Reshuffle.viaRandomKey(), it worked

[jira] [Updated] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TJ updated BEAM-8121: - Description: Messages are consumed from Kafka using KafkaIO. Each kafka topic contains only 1 partition. (That means that

[jira] [Created] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

TJ created BEAM-8121: Summary: Messages are not distributed per machines when consuming from Kafka topic with 1 partition Key: BEAM-8121 URL: https://issues.apache.org/jira/browse/BEAM-8121 Project: Beam