[jira] [Commented] (KAFKA-9702) Suspected memory leak

[ https://issues.apache.org/jira/browse/KAFKA-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056739#comment-17056739 ] Alexandre Dupriez commented on KAFKA-9702: -- Could you please provide a link to a stored heap

[jira] [Commented] (KAFKA-9702) Suspected memory leak

[ https://issues.apache.org/jira/browse/KAFKA-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056738#comment-17056738 ] Nishant Ranjan commented on KAFKA-9702: --- When I execute proper code on linux server with approx

[jira] [Commented] (KAFKA-9702) Suspected memory leak

[ https://issues.apache.org/jira/browse/KAFKA-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056725#comment-17056725 ] Alexandre Dupriez commented on KAFKA-9702: -- 22,33,048 bytes - do you mean 22 MB? > Suspected

[jira] [Created] (KAFKA-9702) Suspected memory leak

Nishant Ranjan created KAFKA-9702: - Summary: Suspected memory leak Key: KAFKA-9702 URL: https://issues.apache.org/jira/browse/KAFKA-9702 Project: Kafka Issue Type: Bug Components:

[jira] [Updated] (KAFKA-9343) Make Kafka shell runnable on z/OS

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Zhang updated KAFKA-9343: -- Description: To make Kafka runnable on z/OS， I need some changes to the shell script and java/scala

[jira] [Updated] (KAFKA-9343) Add ps command for Kafka and zookeeper process on z/OS.

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Zhang updated KAFKA-9343: -- Description: +Note: since the final change scope changed, I changed the summary and description.+

[jira] [Commented] (KAFKA-9702) Suspected memory leak

[ https://issues.apache.org/jira/browse/KAFKA-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056795#comment-17056795 ] Nishant Ranjan commented on KAFKA-9702: --- Hi Alexandre, I attached hprof dump. What I did this

[jira] [Comment Edited] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021999#comment-17021999 ] hirik edited comment on KAFKA-9458 at 3/11/20, 10:13 AM: - [~manme...@gmail.com],

[jira] [Comment Edited] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021999#comment-17021999 ] hirik edited comment on KAFKA-9458 at 3/11/20, 10:13 AM: - [~manme...@gmail.com],

[jira] [Closed] (KAFKA-9343) Add ps command for Kafka and zookeeper process on z/OS.

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Zhang closed KAFKA-9343. - > Add ps command for Kafka and zookeeper process on z/OS. >

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056819#comment-17056819 ] ASF GitHub Bot commented on KAFKA-9458: --- hirik commented on pull request #8002: KAFKA-9458 Fix

[jira] [Updated] (KAFKA-9343) Add ps command for Kafka and zookeeper process on z/OS.

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Zhang updated KAFKA-9343: -- Fix Version/s: (was: 2.6.0) 2.5.0 Description: +Note: since the final

[jira] [Created] (KAFKA-9703) ProducerBatch.split takes up too many resources if the bigBatch is huge

jiamei xie created KAFKA-9703: - Summary: ProducerBatch.split takes up too many resources if the bigBatch is huge Key: KAFKA-9703 URL: https://issues.apache.org/jira/browse/KAFKA-9703 Project: Kafka

[jira] [Updated] (KAFKA-9702) Suspected memory leak

[ https://issues.apache.org/jira/browse/KAFKA-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nishant Ranjan updated KAFKA-9702: -- Attachment: java_pid8020.0001.hprof.7z > Suspected memory leak > - > >

[jira] [Commented] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll

[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056893#comment-17056893 ] Paolo Moriello commented on KAFKA-9693: --- [~junrao] Thanks for the interest! To answer your

[jira] [Created] (KAFKA-9704) z/OS won't let us resize file when mmap

Shuo Zhang created KAFKA-9704: - Summary: z/OS won't let us resize file when mmap Key: KAFKA-9704 URL: https://issues.apache.org/jira/browse/KAFKA-9704 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-9702) Suspected memory leak

[ https://issues.apache.org/jira/browse/KAFKA-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nishant Ranjan updated KAFKA-9702: -- Attachment: java_pid8020.0001_Leak_Suspects.zip > Suspected memory leak >

[jira] [Commented] (KAFKA-9698) Wrong default max.message.bytes in document

[ https://issues.apache.org/jira/browse/KAFKA-9698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056751#comment-17056751 ] Tom Bentley commented on KAFKA-9698: KAFKA-4203 has been fixed for Kafka 2.5 which is not released

[jira] [Updated] (KAFKA-9343) Add ps command for Kafka and zookeeper process on z/OS.

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Zhang updated KAFKA-9343: -- Description: (was: +Note: since the final change scope changed, I changed the summary and

[jira] [Updated] (KAFKA-9343) Add ps command for Kafka and zookeeper process on z/OS.

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Zhang updated KAFKA-9343: -- Fix Version/s: 2.4.2 > Add ps command for Kafka and zookeeper process on z/OS. >

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057281#comment-17057281 ] Raman Gupta commented on KAFKA-8803: [~guozhang] FYI we had this happen again today, and this time I

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057279#comment-17057279 ] Guozhang Wang commented on KAFKA-8803: -- https://github.com/apache/kafka/pull/8269 > Stream will not

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057191#comment-17057191 ] Raman Gupta commented on KAFKA-8803: Any progress on this? Still happening regularly for us. >

[jira] [Commented] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll

[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057256#comment-17057256 ] Jun Rao commented on KAFKA-9693: [~paolomoriello]: Thanks for the reply. Do you know if the increase

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057262#comment-17057262 ] Raman Gupta commented on KAFKA-8803: Thanks [~guozhang]. I'm a little confused by your response.

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057269#comment-17057269 ] Guozhang Wang commented on KAFKA-8803: -- [~oleksii.boiko] indeed had a great observation about one

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057241#comment-17057241 ] Guozhang Wang commented on KAFKA-8803: -- [~rocketraman] Yes here are the current status: 1) On the

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Attachment: logs-client-20200311.txt.gz logs-20200311.txt.gz > Stream will not st

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

, but as long as the client side didn't restart, things were ok. Just a theory though. There is no IllegalStateException as seen by [~oleksii.boiko]. [^logs-20200311.txt.gz] [^logs-client-20200311.txt.gz] > Stream will not start due to TimeoutException: Timeout expired af

[jira] [Commented] (KAFKA-1336) Create partition compaction analyzer

[ https://issues.apache.org/jira/browse/KAFKA-1336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057373#comment-17057373 ] Sönke Liebau commented on KAFKA-1336: - While I agree in principle that this information might be

[jira] [Updated] (KAFKA-5972) Flatten SMT does not work with null values

[ https://issues.apache.org/jira/browse/KAFKA-5972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-5972: --- Fix Version/s: 2.2.2 2.4.0 2.3.1 2.1.2

[jira] [Resolved] (KAFKA-5972) Flatten SMT does not work with null values

[ https://issues.apache.org/jira/browse/KAFKA-5972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-5972. Resolution: Fixed > Flatten SMT does not work with null values >

[jira] [Commented] (KAFKA-1440) Per-request tracing

[ https://issues.apache.org/jira/browse/KAFKA-1440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057379#comment-17057379 ] Sönke Liebau commented on KAFKA-1440: - Looking through some old tickets and came across this. While

[jira] [Commented] (KAFKA-1518) KafkaMetricsReporter prevents Kafka from starting if the custom reporter throws an exception

[ https://issues.apache.org/jira/browse/KAFKA-1518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057389#comment-17057389 ] Sönke Liebau commented on KAFKA-1518: - Personally I'd say, that this behavior is fine. If you don't

[jira] [Created] (KAFKA-9706) Flatten transformation fails when encountering tombstone event

Greg Harris created KAFKA-9706: -- Summary: Flatten transformation fails when encountering tombstone event Key: KAFKA-9706 URL: https://issues.apache.org/jira/browse/KAFKA-9706 Project: Kafka

[jira] [Commented] (KAFKA-1265) SBT and Gradle create jars without expected Maven files

[ https://issues.apache.org/jira/browse/KAFKA-1265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057365#comment-17057365 ] Sönke Liebau commented on KAFKA-1265: - While it still holds true that the jar itself doesn't contain

[jira] [Resolved] (KAFKA-1292) Command-line tools should print what they do as part of their usage command

[ https://issues.apache.org/jira/browse/KAFKA-1292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sönke Liebau resolved KAFKA-1292. - Resolution: Fixed This has been implemented by now, I do believe within the linked ticket. >

[jira] [Commented] (KAFKA-1231) Support partition shrink (delete partition)

[ https://issues.apache.org/jira/browse/KAFKA-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057392#comment-17057392 ] Sönke Liebau commented on KAFKA-1231: - To be honest I think this caters to a bit of a fringe case and

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057296#comment-17057296 ] Guozhang Wang commented on KAFKA-8803: -- Raman, could you share the broker-side logs (everything, the

[jira] [Commented] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll

[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057313#comment-17057313 ] Paolo Moriello commented on KAFKA-9693: --- [~junrao] thank you again for you replay. To clarify, when

[jira] [Commented] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll

[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057325#comment-17057325 ] Jun Rao commented on KAFKA-9693: [~paolomoriello]: By metadata, I was referring to the metadata in the

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057285#comment-17057285 ] Guozhang Wang edited comment on KAFKA-8803 at 3/11/20, 6:09 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057285#comment-17057285 ] Guozhang Wang commented on KAFKA-8803: -- [~rocketraman] "and due to time shift which may indeed be

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057285#comment-17057285 ] Guozhang Wang edited comment on KAFKA-8803 at 3/11/20, 6:08 PM:

[jira] [Created] (KAFKA-9705) (Incremental)AlterConfig should be propagated from Controller in bridge release

Boyang Chen created KAFKA-9705: -- Summary: (Incremental)AlterConfig should be propagated from Controller in bridge release Key: KAFKA-9705 URL: https://issues.apache.org/jira/browse/KAFKA-9705 Project:

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057291#comment-17057291 ] Guozhang Wang commented on KAFKA-8803: -- [~rocketraman] Also about your reported

[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057452#comment-17057452 ] ASF GitHub Bot commented on KAFKA-6145: --- ableegoldman commented on pull request #8282: KAFKA-6145:

[jira] [Commented] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057459#comment-17057459 ] ASF GitHub Bot commented on KAFKA-9701: --- guozhangwang commented on pull request #8272: KAFKA-9701:

[jira] [Commented] (KAFKA-5972) Flatten SMT does not work with null values

[ https://issues.apache.org/jira/browse/KAFKA-5972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057468#comment-17057468 ] ASF GitHub Bot commented on KAFKA-5972: --- rhauch commented on pull request #4021: KAFKA-5972 Flatten

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057276#comment-17057276 ] ASF GitHub Bot commented on KAFKA-8803: --- guozhangwang commented on pull request #8278: KAFKA-8803:

[jira] [Commented] (KAFKA-9706) Flatten transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057408#comment-17057408 ] ASF GitHub Bot commented on KAFKA-9706: --- gharris1727 commented on pull request #8279: KAFKA-9706:

[jira] [Created] (KAFKA-9707) InsertField.Key transformation does not apply to tombstone records

Greg Harris created KAFKA-9707: -- Summary: InsertField.Key transformation does not apply to tombstone records Key: KAFKA-9707 URL: https://issues.apache.org/jira/browse/KAFKA-9707 Project: Kafka

[jira] [Commented] (KAFKA-9707) InsertField.Key transformation does not apply to tombstone records

[ https://issues.apache.org/jira/browse/KAFKA-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057429#comment-17057429 ] ASF GitHub Bot commented on KAFKA-9707: --- gharris1727 commented on pull request #8280: KAFKA-9707:

[jira] [Commented] (KAFKA-9605) EOS Producer could throw illegal state if trying to complete a failed batch after fatal error

[ https://issues.apache.org/jira/browse/KAFKA-9605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057443#comment-17057443 ] ASF GitHub Bot commented on KAFKA-9605: --- hachikuji commented on pull request #8177: KAFKA-9605: Do

[jira] [Resolved] (KAFKA-9605) EOS Producer could throw illegal state if trying to complete a failed batch after fatal error

[ https://issues.apache.org/jira/browse/KAFKA-9605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9605. Resolution: Fixed > EOS Producer could throw illegal state if trying to complete a failed

[jira] [Created] (KAFKA-9708) Connector does not prefer to use packaged classes during configuration

Greg Harris created KAFKA-9708: -- Summary: Connector does not prefer to use packaged classes during configuration Key: KAFKA-9708 URL: https://issues.apache.org/jira/browse/KAFKA-9708 Project: Kafka

[jira] [Commented] (KAFKA-9708) Connector does not prefer to use packaged classes during configuration

[ https://issues.apache.org/jira/browse/KAFKA-9708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057438#comment-17057438 ] ASF GitHub Bot commented on KAFKA-9708: --- gharris1727 commented on pull request #8281: KAFKA-9708:

[jira] [Commented] (KAFKA-9451) Pass consumer group metadata to producer on commit

[ https://issues.apache.org/jira/browse/KAFKA-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057441#comment-17057441 ] ASF GitHub Bot commented on KAFKA-9451: --- mjsax commented on pull request #8215: KAFKA-9451: Update

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057442#comment-17057442 ] Matthias J. Sax commented on KAFKA-7965:

[jira] [Created] (KAFKA-9709) add a confirm when kafka-server-stop.sh find multiple kafka instances to kill

qiang Liu created KAFKA-9709: Summary: add a confirm when kafka-server-stop.sh find multiple kafka instances to kill Key: KAFKA-9709 URL: https://issues.apache.org/jira/browse/KAFKA-9709 Project: Kafka

[jira] [Commented] (KAFKA-9709) add a confirm when kafka-server-stop.sh find multiple kafka instances to kill

[ https://issues.apache.org/jira/browse/KAFKA-9709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057519#comment-17057519 ] qiang Liu commented on KAFKA-9709: -- create a pull request [https://github.com/apache/kafka/pull/8275]