[jira] [Commented] (KAFKA-8089) High level consumer from MirrorMaker is slow to deal with SSL certification expiration

2019-03-13 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791509#comment-16791509 ] Rajini Sivaram commented on KAFKA-8089: --- We improved authentication failure handlin

[jira] [Assigned] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up

2019-03-13 Thread Attila Sasvari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-6332: - Assignee: (was: Attila Sasvari) > Kafka system tests should use nc instead of log gr

[jira] [Created] (KAFKA-8100) If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log

2019-03-13 Thread Shengnan YU (JIRA)
Shengnan YU created KAFKA-8100: -- Summary: If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log Key: KAFKA-8100 URL: https://issues.apache.org/jira/browse/KAFKA-8100 Pro

[jira] [Commented] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up

2019-03-13 Thread Attila Sasvari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791592#comment-16791592 ] Attila Sasvari commented on KAFKA-6332: --- Feel free to take it over. > Kafka system

[jira] [Created] (KAFKA-8101) Optimization Has Different Processor Node Count on Scala API

2019-03-13 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8101: -- Summary: Optimization Has Different Processor Node Count on Scala API Key: KAFKA-8101 URL: https://issues.apache.org/jira/browse/KAFKA-8101 Project: Kafka Issue

[jira] [Created] (KAFKA-8102) Trogdor - Add Produce workload transaction generator by interval

2019-03-13 Thread Stanislav Kozlovski (JIRA)
Stanislav Kozlovski created KAFKA-8102: -- Summary: Trogdor - Add Produce workload transaction generator by interval Key: KAFKA-8102 URL: https://issues.apache.org/jira/browse/KAFKA-8102 Project: K

[jira] [Updated] (KAFKA-8102) Trogdor - Add Produce workload transaction generator by interval

2019-03-13 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8102: --- Description: Trogdor's specification for produce worker workloads ([ProduceBenchSpec

[jira] [Created] (KAFKA-8103) Kafka SIGSEGV on kafka-network-thread

2019-03-13 Thread Sean Humbarger (JIRA)
Sean Humbarger created KAFKA-8103: - Summary: Kafka SIGSEGV on kafka-network-thread Key: KAFKA-8103 URL: https://issues.apache.org/jira/browse/KAFKA-8103 Project: Kafka Issue Type: Bug Aff

[jira] [Updated] (KAFKA-8103) Kafka SIGSEGV on kafka-network-thread

2019-03-13 Thread Sean Humbarger (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Humbarger updated KAFKA-8103: -- Environment: OS Amazon Linux Kernel 4.14.97-74.72.amzn1.x86_64 #1 SMP Tue Feb 5 20:59:30 UTC

[jira] [Updated] (KAFKA-8103) Kafka SIGSEGV on kafka-network-thread

2019-03-13 Thread Sean Humbarger (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Humbarger updated KAFKA-8103: -- Description: We have a 4 node cluster (6 topics, 6 consumer groups) that is processing 65,000

[jira] [Assigned] (KAFKA-7565) NPE in KafkaConsumer

2019-03-13 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio reassigned KAFKA-7565: - Assignee: (was: Jose Armando Garcia Sancio) > NPE in KafkaCo

[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

2019-03-13 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791912#comment-16791912 ] Jose Armando Garcia Sancio commented on KAFKA-7565: --- The Github PR 6427

[jira] [Commented] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

2019-03-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791910#comment-16791910 ] Jun Rao commented on KAFKA-6029: [~hzxa21], do you still plan to work on this? Thanks. >

[jira] [Updated] (KAFKA-8101) Different Processor Node Count on Scala API

2019-03-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8101: --- Summary: Different Processor Node Count on Scala API (was: Optimization Has Different Processor Node

[jira] [Commented] (KAFKA-8101) Optimization Has Different Processor Node Count on Scala API

2019-03-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791984#comment-16791984 ] Bill Bejeck commented on KAFKA-8101: Update This is actually a bug within our Scala A

[jira] [Updated] (KAFKA-8101) Different Processor Node Count on Scala API

2019-03-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8101: --- Description: Surfaced from this PR [https://github.com/apache/kafka/pull/6373] But two topologies ha

[jira] [Commented] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter

2019-03-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792005#comment-16792005 ] Matthias J. Sax commented on KAFKA-7606: Marking this as blocker so we don't forg

[jira] [Updated] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter

2019-03-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7606: --- Priority: Blocker (was: Trivial) > Remove deprecated --zookeeper option from StreamsResetter

[jira] [Created] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
Gregory Koshelev created KAFKA-8104: --- Summary: Consumer cannot rejoin to the group after rebalancing Key: KAFKA-8104 URL: https://issues.apache.org/jira/browse/KAFKA-8104 Project: Kafka Iss

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Attachment: consumer-rejoin-fail.log > Consumer cannot rejoin to the group after rebalancin

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Commented] (KAFKA-6340) Support of transactions in KafkaConnect

2019-03-13 Thread Ryanne Dolan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792052#comment-16792052 ] Ryanne Dolan commented on KAFKA-6340: - Do we think we need a KIP for this change? For

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Description: TL;DR; {{KafkaConsumer}} cannot rejoin to the group due to inconsistent {{Abs

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gregory Koshelev updated KAFKA-8104: Priority: Critical (was: Major) > Consumer cannot rejoin to the group after rebalancing >

[jira] [Commented] (KAFKA-7133) DisconnectException every 5 minutes in single restore consumer thread

2019-03-13 Thread Shahar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792108#comment-16792108 ] Shahar commented on KAFKA-7133: --- We're having this issues as well after setting "auto.offse

[jira] [Resolved] (KAFKA-8101) Different Processor Node Count on Scala API

2019-03-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8101. Resolution: Not A Bug There is a known issue with KGroupedStream#count in the Scala API where there

[jira] [Commented] (KAFKA-8093) Fix JavaDoc markup

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792175#comment-16792175 ] ASF GitHub Bot commented on KAFKA-8093: --- pkleindl commented on pull request #6439:

[jira] [Commented] (KAFKA-7978) Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups

2019-03-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792182#comment-16792182 ] Guozhang Wang commented on KAFKA-7978: -- Failed again: https://builds.apache.org/job

[jira] [Commented] (KAFKA-8101) Different Processor Node Count on Scala API

2019-03-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792196#comment-16792196 ] Matthias J. Sax commented on KAFKA-8101: Do we think we should document this expl

[jira] [Assigned] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

2019-03-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8098: - Assignee: huxihx > Flaky Test AdminClientIntegrationTest#testConsumerGroups > --

[jira] [Commented] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792301#comment-16792301 ] ASF GitHub Bot commented on KAFKA-8098: --- huxihx commented on pull request #6441: KA