[jira] [Commented] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest

2019-12-06 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989491#comment-16989491 ] Jason Gustafson commented on KAFKA-9212: [~mjasc...@twilio.com] Really appreciate

[jira] [Commented] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989590#comment-16989590 ] ASF GitHub Bot commented on KAFKA-9267: --- omkreddy commented on pull request #7778:

[jira] [Resolved] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

2019-12-06 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9267. -- Fix Version/s: 2.5.0 Resolution: Fixed Issue resolved by pull request 7778 [https://github.com/a

[jira] [Created] (KAFKA-9278) Avoid using static instance of DisconnectException

2019-12-06 Thread Qinghui Xu (Jira)
Qinghui Xu created KAFKA-9278: - Summary: Avoid using static instance of DisconnectException Key: KAFKA-9278 URL: https://issues.apache.org/jira/browse/KAFKA-9278 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9278) Avoid using static instance of DisconnectException

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989702#comment-16989702 ] ASF GitHub Bot commented on KAFKA-9278: --- qinghui-xu commented on pull request #7788

[jira] [Created] (KAFKA-9279) Silent data loss in Kafka producer

2019-12-06 Thread Andrew Klopper (Jira)
Andrew Klopper created KAFKA-9279: - Summary: Silent data loss in Kafka producer Key: KAFKA-9279 URL: https://issues.apache.org/jira/browse/KAFKA-9279 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9279) Silent data loss in Kafka producer

2019-12-06 Thread Mattia Barbon (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989729#comment-16989729 ] Mattia Barbon commented on KAFKA-9279: -- This is affecting out team as well, with cli

[jira] [Created] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL

2019-12-06 Thread VIkram (Jira)
VIkram created KAFKA-9280: - Summary: Duplicate messages are observed in ACK mode ALL Key: KAFKA-9280 URL: https://issues.apache.org/jira/browse/KAFKA-9280 Project: Kafka Issue Type: Bug Affects V

[jira] [Commented] (KAFKA-9279) Silent data loss in Kafka producer

2019-12-06 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989894#comment-16989894 ] Boyang Chen commented on KAFKA-9279: Hey there, what's the expected behavior in this

[jira] [Commented] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL

2019-12-06 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989904#comment-16989904 ] Boyang Chen commented on KAFKA-9280: I think the log for consumer is missing. There i

[jira] [Updated] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7489: - Affects Version/s: 2.3.2 2.2.3 2.1.2 > ConnectDistr

[jira] [Updated] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7489: - Affects Version/s: (was: 2.3.2) (was: 2.2.3)

[jira] [Commented] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989954#comment-16989954 ] Randall Hauch commented on KAFKA-7489: -- This is fixed in `2.4` and `trunk` per http

[jira] [Commented] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989958#comment-16989958 ] ASF GitHub Bot commented on KAFKA-7489: --- rhauch commented on pull request #7791: KA

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

2019-12-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989968#comment-16989968 ] John Roesler commented on KAFKA-9270: - Hi [~rohan26may], No problem. I was actually

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

2019-12-06 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989974#comment-16989974 ] Boyang Chen commented on KAFKA-9274: Thanks for the summary John. I think what we par

[jira] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

2019-12-06 Thread Cory (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989975#comment-16989975 ] Cory commented on KAFKA-6522: - Our team had a similar issue.  # A developer had spun up a lo

[jira] [Issue Comment Deleted] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

2019-12-06 Thread Cory (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cory updated KAFKA-6522: Comment: was deleted (was: Our team had a similar issue.  # A developer had spun up a local kafka cluster using th

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

2019-12-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989980#comment-16989980 ] John Roesler commented on KAFKA-9274: - Yep, something like that is what I would propo

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989995#comment-16989995 ] ASF GitHub Bot commented on KAFKA-8803: --- abbccdda commented on pull request #7766:

[jira] [Updated] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7489: - Fix Version/s: 2.3.2 2.2.3 2.1.2 > ConnectDistributedTest i

[jira] [Assigned] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-7489: Assignee: Randall Hauch > ConnectDistributedTest is always running broker with dev version

[jira] [Comment Edited] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989954#comment-16989954 ] Randall Hauch edited comment on KAFKA-7489 at 12/6/19 6:02 PM:

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-12-06 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990054#comment-16990054 ] Raman Gupta commented on KAFKA-8803: [~bchen225242] I see the pull request adds a ret

[jira] [Created] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

2019-12-06 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9281: -- Summary: Consider more flexible node grouping for Pattern subscription Key: KAFKA-9281 URL: https://issues.apache.org/jira/browse/KAFKA-9281 Project: Kafk

[jira] [Created] (KAFKA-9282) Consider more flexible node grouping for Pattern subscription

2019-12-06 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9282: -- Summary: Consider more flexible node grouping for Pattern subscription Key: KAFKA-9282 URL: https://issues.apache.org/jira/browse/KAFKA-9282 Project: Kafk

[jira] [Commented] (KAFKA-9091) KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990099#comment-16990099 ] ASF GitHub Bot commented on KAFKA-9091: --- cmccabe commented on pull request #7588: K

[jira] [Commented] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990118#comment-16990118 ] ASF GitHub Bot commented on KAFKA-7489: --- rhauch commented on pull request #7791: KA

[jira] [Resolved] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

2019-12-06 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-7489. -- Reviewer: John Roesler Resolution: Fixed Merged this to the `2.3`, `2.2`., and `2.1` bran

[jira] [Commented] (KAFKA-7588) Rationalize configurations passed to pluggable APIs

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990133#comment-16990133 ] ASF GitHub Bot commented on KAFKA-7588: --- omkreddy commented on pull request #7794:

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

2019-12-06 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990136#comment-16990136 ] Sophie Blee-Goldman commented on KAFKA-9173: [~o.muravskiy] Opened [this PR|[

[jira] [Comment Edited] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

2019-12-06 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990136#comment-16990136 ] Sophie Blee-Goldman edited comment on KAFKA-9173 at 12/6/19 8:03 PM: --

[jira] [Created] (KAFKA-9283) Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

2019-12-06 Thread Israel Ekpo (Jira)
Israel Ekpo created KAFKA-9283: -- Summary: Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker Key: KAFKA-9283 URL: https://issues.apache.org/jira/browse/KAFKA-9283

[jira] [Updated] (KAFKA-9283) Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

2019-12-06 Thread Israel Ekpo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Israel Ekpo updated KAFKA-9283: --- Description: This same test fails occasionally on when run in Scala  2.12.10 but has been failing co

[jira] [Updated] (KAFKA-9283) Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

2019-12-06 Thread Israel Ekpo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Israel Ekpo updated KAFKA-9283: --- Description: This same test fails occasionally on when run in Scala  2.12.10 but has been failing co

[jira] [Created] (KAFKA-9284) Add documentation and system tests for TLS-encrypted Zookeeper connections

2019-12-06 Thread Ron Dagostino (Jira)
Ron Dagostino created KAFKA-9284: Summary: Add documentation and system tests for TLS-encrypted Zookeeper connections Key: KAFKA-9284 URL: https://issues.apache.org/jira/browse/KAFKA-9284 Project: Kaf

[jira] [Commented] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

2019-12-06 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990271#comment-16990271 ] Guozhang Wang commented on KAFKA-9281: -- [~ableegoldman] Seems like you created a dup

[jira] [Commented] (KAFKA-9260) Improve Serde "push down" and "wrapping"

2019-12-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990279#comment-16990279 ] Matthias J. Sax commented on KAFKA-9260: That sounds like a good fix! However, I

[jira] [Commented] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

2019-12-06 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990281#comment-16990281 ] Sophie Blee-Goldman commented on KAFKA-9281: Haha whoops...I was lead to beli

[jira] [Resolved] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

2019-12-06 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9281. Resolution: Duplicate > Consider more flexible node grouping for Pattern subscripti

[jira] [Commented] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest

2019-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990283#comment-16990283 ] ASF GitHub Bot commented on KAFKA-9212: --- hachikuji commented on pull request #7795:

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-12-06 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990286#comment-16990286 ] Guozhang Wang commented on KAFKA-8803: -- [~rocketraman] [~timvanlaer] Based on the cu

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

2019-12-06 Thread dengziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990300#comment-16990300 ] dengziming commented on KAFKA-9275: --- Our company now encounters some problems with reba

[jira] [Created] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

2019-12-06 Thread Richard Yu (Jira)
Richard Yu created KAFKA-9285: - Summary: Implement failed message topic to account for processing lag during failure Key: KAFKA-9285 URL: https://issues.apache.org/jira/browse/KAFKA-9285 Project: Kafka

[jira] [Commented] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

2019-12-06 Thread Richard Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990303#comment-16990303 ] Richard Yu commented on KAFKA-9285: --- cc [~bchen225242] You might be interested in this.

[jira] [Updated] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

2019-12-06 Thread Richard Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-9285: -- Description: Presently, in current Kafka failure schematics, when a consumer crashes, the user is typi

[jira] [Assigned] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

2019-12-06 Thread Richard Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu reassigned KAFKA-9285: - Assignee: Richard Yu > Implement failed message topic to account for processing lag during failu

[jira] [Updated] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

2019-12-06 Thread Richard Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-9285: -- Labels: kip (was: ) > Implement failed message topic to account for processing lag during failure > --

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

2019-12-06 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990311#comment-16990311 ] John Roesler commented on KAFKA-9275: - Hi [~dengziming], It looks like you should be

[jira] [Assigned] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

2019-12-06 Thread dengziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming reassigned KAFKA-9275: - Assignee: dengziming > Print assignment and IP address in the log message when consumer > leave