[jira] [Updated] (KAFKA-9210) kafka stream loss data

2019-11-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9210: --- Description: kafka broker: 2.0.1 kafka stream client: 2.1.0 # two applications run at the s

[jira] [Updated] (KAFKA-9210) kafka stream loss data

2019-11-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9210: --- Description: kafka broker: 2.0.1 kafka stream client: 2.1.0 # two applications run at the s

[jira] [Updated] (KAFKA-9210) kafka stream loss data

2019-11-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9210: --- Component/s: streams > kafka stream loss data > -- > > Ke

[jira] [Commented] (KAFKA-9157) logcleaner could generate empty segment files after cleaning

2019-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977306#comment-16977306 ] ASF GitHub Bot commented on KAFKA-9157: --- huxihx commented on pull request #7711: KA

[jira] [Commented] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

2019-11-19 Thread David Watzke (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977373#comment-16977373 ] David Watzke commented on KAFKA-9203: - producer is using kafka client 0.10.2.1 > kaf

[jira] [Comment Edited] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

2019-11-19 Thread David Watzke (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977373#comment-16977373 ] David Watzke edited comment on KAFKA-9203 at 11/19/19 10:55 AM: ---

[jira] [Commented] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

2019-11-19 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977528#comment-16977528 ] Ismael Juma commented on KAFKA-9203: Are you able to swap the lz4 jar when when runni

[jira] [Created] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

2019-11-19 Thread li xiangyuan (Jira)
li xiangyuan created KAFKA-9211: --- Summary: kafka upgrade 2.3.0 cause produce speed decrease Key: KAFKA-9211 URL: https://issues.apache.org/jira/browse/KAFKA-9211 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

2019-11-19 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977539#comment-16977539 ] Ismael Juma commented on KAFKA-9211: cc [~junrao] > kafka upgrade 2.3.0 cause produc

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

2019-11-19 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977577#comment-16977577 ] Raman Gupta commented on KAFKA-8803: We had this problem again today, and checked on

[jira] [Commented] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

2019-11-19 Thread Vahid Hashemian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977592#comment-16977592 ] Vahid Hashemian commented on KAFKA-9205: [~sbellapu] KIP process is not that diff

[jira] [Commented] (KAFKA-9086) Refactor Processor Node Streams Metrics

2019-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977668#comment-16977668 ] ASF GitHub Bot commented on KAFKA-9086: --- bbejeck commented on pull request #7615: K

[jira] [Resolved] (KAFKA-9086) Refactor Processor Node Streams Metrics

2019-11-19 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9086. Resolution: Fixed > Refactor Processor Node Streams Metrics > -

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

2019-11-19 Thread Jan Arve Sundt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1690#comment-1690 ] Jan Arve Sundt commented on KAFKA-7500: --- I'm testing to replicate all topics from o

[jira] [Commented] (KAFKA-9178) restoredPartitions is not cleared until the last restoring task completes

2019-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977854#comment-16977854 ] ASF GitHub Bot commented on KAFKA-9178: --- ableegoldman commented on pull request #76

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

2019-11-19 Thread Yannick (Jira)
Yannick created KAFKA-9212: -- Summary: Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest Key: KAFKA-9212 URL: https://issues.apache.org/jira/browse/KAFKA-9212 Project: Kafka Issue T

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

2019-11-19 Thread Yannick (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yannick updated KAFKA-9212: --- Description: When running Kafka connect s3 sink connector ( confluent 5.3.0), after one broker got restarted

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

2019-11-19 Thread Yannick (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yannick updated KAFKA-9212: --- Description: When running Kafka connect s3 sink connector ( confluent 5.3.0), after one broker got restarted

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

2019-11-19 Thread Yannick (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yannick updated KAFKA-9212: --- Description: When running Kafka connect s3 sink connector ( confluent 5.3.0), after one broker got restarted

[jira] [Commented] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

2019-11-19 Thread sats (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977902#comment-16977902 ] sats commented on KAFKA-9205: - Cool let me dig into it, thanks. [~vahid] > Add an option to

[jira] [Created] (KAFKA-9213) BufferOverflowException on rolling new segment after upgrading Kafka from 1.1.0 to 2.3.1

2019-11-19 Thread Daniyar (Jira)
Daniyar created KAFKA-9213: -- Summary: BufferOverflowException on rolling new segment after upgrading Kafka from 1.1.0 to 2.3.1 Key: KAFKA-9213 URL: https://issues.apache.org/jira/browse/KAFKA-9213 Project: K

[jira] [Commented] (KAFKA-6962) DescribeConfigsRequest Schema documentation is wrong/missing detail

2019-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977948#comment-16977948 ] ASF GitHub Bot commented on KAFKA-6962: --- kdrakon commented on pull request #5091: K

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

2019-11-19 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9212: --- Priority: Critical (was: Major) > Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest

[jira] [Updated] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

2019-11-19 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9203: --- Priority: Critical (was: Major) > kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka

[jira] [Created] (KAFKA-9214) test suite generates different errors each time

2019-11-19 Thread AK97 (Jira)
AK97 created KAFKA-9214: --- Summary: test suite generates different errors each time Key: KAFKA-9214 URL: https://issues.apache.org/jira/browse/KAFKA-9214 Project: Kafka Issue Type: Bug Affects Versi

[jira] [Commented] (KAFKA-9051) Source task source offset reads can block graceful shutdown

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

[jira] [Updated] (KAFKA-9051) Source task source offset reads can block graceful shutdown

2019-11-19 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9051: - Fix Version/s: 2.3.2 2.5.0 2.2.3 2.1.2

[jira] [Resolved] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

2019-11-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-9208. --- Resolution: Duplicate > Flaky Test SslAdminClientIntegrationTest.testCreatePartitions > -

[jira] [Reopened] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

2019-11-19 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9208: Note that this test is distinct from the similar flaky test AdminClientIntegrationTest