[jira] [Commented] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909546#comment-16909546 ] panpan.liu commented on KAFKA-3917: --- [~boquan] I restart kafka broker，It may lose data sometimes（not

[jira] [Commented] (KAFKA-8601) Producer Improvement: Sticky Partitioner

[ https://issues.apache.org/jira/browse/KAFKA-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909469#comment-16909469 ] ASF GitHub Bot commented on KAFKA-8601: --- cmccabe commented on pull request #7199: KAFKA-8601:

[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909457#comment-16909457 ] Chris Pettitt commented on KAFKA-8755: -- One last note: A huge thanks to [~cadonna] who has a super

[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909450#comment-16909450 ] Chris Pettitt commented on KAFKA-8755: -- Wrapping up for today. I suspect this is due to overloading

[jira] [Commented] (KAFKA-8806) Kafka.poll spends significant amount of time in KafkaConsumer.updateAssignmentMetadataIfNeeded

[ https://issues.apache.org/jira/browse/KAFKA-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909445#comment-16909445 ] Richard Yu commented on KAFKA-8806: --- [~vvcephei] Since you wrote this part of the code, your thoughts

[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909401#comment-16909401 ] Chris Pettitt commented on KAFKA-8755: -- Fixing the above bug, we at least are getting sane looking

[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909398#comment-16909398 ] Chris Pettitt commented on KAFKA-8755: -- [~guozhang] Finding what looks to be a few odd bugs as I get

[jira] [Commented] (KAFKA-8766) Allow a custom offset policy for Kafka Streams applications

[ https://issues.apache.org/jira/browse/KAFKA-8766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909316#comment-16909316 ] Raman Gupta commented on KAFKA-8766: See KAFKA-8650 for related discussion. > Allow a custom offset

[jira] [Commented] (KAFKA-8810) Add mechanism to detect topology mismatch between streams instances

[ https://issues.apache.org/jira/browse/KAFKA-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909315#comment-16909315 ] Patrik Kleindl commented on KAFKA-8810: --- We have encountered the same issue. Without knowing Johns

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909314#comment-16909314 ] Vinoth Chandar commented on KAFKA-7149: --- To close the loop on turning on compression on the backing

[jira] [Commented] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909301#comment-16909301 ] ASF GitHub Bot commented on KAFKA-8802: --- vvcephei commented on pull request #7213: [DO NOT MERGE]

[jira] [Commented] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

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

[jira] [Commented] (KAFKA-8600) Replace DescribeDelegationToken request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909254#comment-16909254 ] ASF GitHub Bot commented on KAFKA-8600: --- omkreddy commented on pull request #7154: KAFKA-8600: Use

[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909249#comment-16909249 ] Chris Pettitt commented on KAFKA-8755: -- Also, I'll fix up the test a bit. It fails in the non

[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909242#comment-16909242 ] Chris Pettitt commented on KAFKA-8755: -- Digging into this a bit. One initial observation is that 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: --- Description: One streams app is consistently failing at startup with the following exception:

[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: screenshot-1.png > Stream will not start due to TimeoutException: Timeout expired after

[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: --- Description: One streams app is consistently failing at startup with the following exception:

[jira] [Created] (KAFKA-8810) Add mechanism to detect topology mismatch between streams instances

Vinoth Chandar created KAFKA-8810: - Summary: Add mechanism to detect topology mismatch between streams instances Key: KAFKA-8810 URL: https://issues.apache.org/jira/browse/KAFKA-8810 Project: Kafka

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909140#comment-16909140 ] Vinoth Chandar commented on KAFKA-7149: --- [~guozhang] Ping ping :) > Reduce assignment data size

[jira] [Assigned] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown

[ https://issues.apache.org/jira/browse/KAFKA-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8807: -- Assignee: Bill Bejeck > Flaky Test >

[jira] [Assigned] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8802: -- Assignee: Sophie Blee-Goldman > ConcurrentSkipListMap shows performance regression in cache

[jira] [Commented] (KAFKA-8809) Infinite retry if secure cluster tried to be reached from non-secure consumer

[ https://issues.apache.org/jira/browse/KAFKA-8809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909033#comment-16909033 ] Gabor Somogyi commented on KAFKA-8809: -- cc [~viktorsomogyi] > Infinite retry if secure cluster

[jira] [Created] (KAFKA-8809) Infinite retry if secure cluster tried to be reached from non-secure consumer

Gabor Somogyi created KAFKA-8809: Summary: Infinite retry if secure cluster tried to be reached from non-secure consumer Key: KAFKA-8809 URL: https://issues.apache.org/jira/browse/KAFKA-8809 Project:

[jira] [Created] (KAFKA-8808) Kafka Inconsistent Retention Period across partitions

Prashant created KAFKA-8808: --- Summary: Kafka Inconsistent Retention Period across partitions Key: KAFKA-8808 URL: https://issues.apache.org/jira/browse/KAFKA-8808 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-8592) Broker Dynamic Configuration fails to resolve variables as per KIP-421

[ https://issues.apache.org/jira/browse/KAFKA-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8592. --- Resolution: Fixed > Broker Dynamic Configuration fails to resolve variables as per KIP-421

[jira] [Commented] (KAFKA-8592) Broker Dynamic Configuration fails to resolve variables as per KIP-421

[ https://issues.apache.org/jira/browse/KAFKA-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908824#comment-16908824 ] ASF GitHub Bot commented on KAFKA-8592: --- rajinisivaram commented on pull request #7031: KAFKA-8592;

[jira] [Commented] (KAFKA-8592) Broker Dynamic Configuration fails to resolve variables as per KIP-421

[ https://issues.apache.org/jira/browse/KAFKA-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908821#comment-16908821 ] Rajini Sivaram commented on KAFKA-8592: --- New PR for this is here:

[jira] [Commented] (KAFKA-8801) electLeaderForPartitions redundancy for some success elect partitions

[ https://issues.apache.org/jira/browse/KAFKA-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908794#comment-16908794 ] huxihx commented on KAFKA-8801: --- Seems it's already fixed in

[jira] [Comment Edited] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908777#comment-16908777 ] Hanumanth Bandi edited comment on KAFKA-4650 at 8/16/19 6:47 AM: -

[jira] [Comment Edited] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908777#comment-16908777 ] Hanumanth Bandi edited comment on KAFKA-4650 at 8/16/19 6:46 AM: -

[jira] [Commented] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908777#comment-16908777 ] Hanumanth Bandi commented on KAFKA-4650: Maththias, Can I pick this ticket.I am newbie to kafka