[jira] [Commented] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586938#comment-16586938 ] Nikolay Izhikov commented on KAFKA-7277: Hello, [~vvcephei]. I've addressed all your comments.

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586927#comment-16586927 ] ASF GitHub Bot commented on KAFKA-7316: --- tedyu opened a new pull request #5543: KAFKA-7316 Use of

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586909#comment-16586909 ] Ted Yu commented on KAFKA-7316: --- Patch v4 makes the code compile. > Use of filter method in KTable.scala

[jira] [Updated] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-7316: -- Attachment: 7316.v4.txt > Use of filter method in KTable.scala may result in StackOverflowError >

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586903#comment-16586903 ] lambdaliu commented on KAFKA-7190: -- Hi [~mjsax], Changing the log level to DEBUG can't avoid the

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586897#comment-16586897 ] Ted Yu commented on KAFKA-7316: --- Patch v2 reduces compilation errors to 20. > Use of filter method in

[jira] [Updated] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-7316: -- Attachment: 7316.v2.txt > Use of filter method in KTable.scala may result in StackOverflowError >

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586886#comment-16586886 ] lambdaliu commented on KAFKA-7190: -- Hi [~hachikuji], sorry for the later reply. I have thought about

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586841#comment-16586841 ] Ted Yu commented on KAFKA-7316: --- [~guozhang] [~mjsax] : Can you take a look at patch v1 to see if the

[jira] [Updated] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-7316: -- Attachment: 7316.v1.txt > Use of filter method in KTable.scala may result in StackOverflowError >

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586738#comment-16586738 ] Ted Yu commented on KAFKA-7316: --- I was thinking about removing the implicit wrapKTable . Then the following

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586709#comment-16586709 ] Matthias J. Sax commented on KAFKA-7315: `Serde` are a Streams concept – it's an abstraction that

[jira] [Updated] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7316: --- Affects Version/s: 2.0.0 > Use of filter method in KTable.scala may result in

[jira] [Updated] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7316: --- Labels: scala (was: ) > Use of filter method in KTable.scala may result in

[jira] [Updated] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7316: --- Component/s: streams > Use of filter method in KTable.scala may result in StackOverflowError

[jira] [Created] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

Ted Yu created KAFKA-7316: - Summary: Use of filter method in KTable.scala may result in StackOverflowError Key: KAFKA-7316 URL: https://issues.apache.org/jira/browse/KAFKA-7316 Project: Kafka Issue

[jira] [Resolved] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5891. Resolution: Fixed Fix Version/s: 2.0.1 1.1.2

[jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586665#comment-16586665 ] ASF GitHub Bot commented on KAFKA-5891: --- hachikuji closed pull request #4633: KAFKA-5891: Proper

[jira] [Comment Edited] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586650#comment-16586650 ] Jordan Moore edited comment on KAFKA-7315 at 8/20/18 11:12 PM: --- What about

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586650#comment-16586650 ] Jordan Moore commented on KAFKA-7315: - What about a separate section on SerDe's outside of the

[jira] [Comment Edited] (KAFKA-6961) UnknownTopicOrPartitionException & NotLeaderForPartitionException upon replication of topics.

[ https://issues.apache.org/jira/browse/KAFKA-6961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586615#comment-16586615 ] Jiangtao Liu edited comment on KAFKA-6961 at 8/20/18 11:08 PM: --- I encounter

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586635#comment-16586635 ] Matthias J. Sax commented on KAFKA-7315: It's just my personal thought :) (I like easy fixes). We

[jira] [Comment Edited] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586629#comment-16586629 ] Jordan Moore edited comment on KAFKA-7315 at 8/20/18 10:56 PM: --- bq. should

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586629#comment-16586629 ] Jordan Moore commented on KAFKA-7315: - bq. should be vendor agnostic and not mention any of them

[jira] [Commented] (KAFKA-6961) UnknownTopicOrPartitionException & NotLeaderForPartitionException upon replication of topics.

[ https://issues.apache.org/jira/browse/KAFKA-6961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586615#comment-16586615 ] Jiangtao Liu commented on KAFKA-6961: - I encounter the same issue after I move Kafka server to new

[jira] [Updated] (KAFKA-6149) LogCleanerManager should include topic partition name when warning of invalid cleaner offset

[ https://issues.apache.org/jira/browse/KAFKA-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6149: -- Component/s: log > LogCleanerManager should include topic partition name when warning of invalid >

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5943: -- Component/s: unit tests > Reduce dependency on mock in connector tests >

[jira] [Updated] (KAFKA-6033) Kafka Streams does not work with musl-libc (alpine linux)

[ https://issues.apache.org/jira/browse/KAFKA-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6033: -- Component/s: streams > Kafka Streams does not work with musl-libc (alpine linux) >

[jira] [Updated] (KAFKA-6149) LogCleanerManager should include topic partition name when warning of invalid cleaner offset

[ https://issues.apache.org/jira/browse/KAFKA-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6149: -- Component/s: logging > LogCleanerManager should include topic partition name when warning of invalid

[jira] [Updated] (KAFKA-6295) Add 'Coordinator Id' to consumer metrics

[ https://issues.apache.org/jira/browse/KAFKA-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6295: -- Component/s: metrics > Add 'Coordinator Id' to consumer metrics >

[jira] [Updated] (KAFKA-6143) VerifiableProducer & VerifiableConsumer need tests

[ https://issues.apache.org/jira/browse/KAFKA-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6143: -- Component/s: system tests > VerifiableProducer & VerifiableConsumer need tests >

[jira] [Updated] (KAFKA-6385) Rack awareness ignored by kafka-reassign-partitions

[ https://issues.apache.org/jira/browse/KAFKA-6385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6385: -- Component/s: tools > Rack awareness ignored by kafka-reassign-partitions >

[jira] [Updated] (KAFKA-6154) Transient failure TransactionsBounceTest.testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-6154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6154: -- Component/s: unit tests > Transient failure TransactionsBounceTest.testBrokerFailure >

[jira] [Updated] (KAFKA-5887) Enable findBugs (or equivalent) when building with Java 9

[ https://issues.apache.org/jira/browse/KAFKA-5887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5887: -- Component/s: build > Enable findBugs (or equivalent) when building with Java 9 >

[jira] [Updated] (KAFKA-7202) Support multiple auto-generated docs formats

[ https://issues.apache.org/jira/browse/KAFKA-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7202: -- Component/s: documentation > Support multiple auto-generated docs formats >

[jira] [Updated] (KAFKA-6823) Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6823: -- Component/s: unit tests > Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize >

[jira] [Updated] (KAFKA-6465) Add a metrics for the number of records per log

[ https://issues.apache.org/jira/browse/KAFKA-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6465: -- Component/s: log > Add a metrics for the number of records per log >

[jira] [Updated] (KAFKA-7166) Links are really difficult to see - insufficient contrast

[ https://issues.apache.org/jira/browse/KAFKA-7166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7166: -- Component/s: documentation > Links are really difficult to see - insufficient contrast >

[jira] [Updated] (KAFKA-7178) Is kafka compatible with zookeeper 3.5.x ?

[ https://issues.apache.org/jira/browse/KAFKA-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7178: -- Component/s: zkclient > Is kafka compatible with zookeeper 3.5.x ? >

[jira] [Updated] (KAFKA-7309) Upgrade Jacoco for Java 11 support

[ https://issues.apache.org/jira/browse/KAFKA-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7309: -- Component/s: packaging > Upgrade Jacoco for Java 11 support > -- > >

[jira] [Updated] (KAFKA-7276) Consider using re2j to speed up regex operations

[ https://issues.apache.org/jira/browse/KAFKA-7276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7276: -- Component/s: packaging > Consider using re2j to speed up regex operations >

[jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586573#comment-16586573 ] ASF GitHub Bot commented on KAFKA-5891: --- rayokota opened a new pull request #5537: KAFKA-5891:

[jira] [Commented] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade

[ https://issues.apache.org/jira/browse/KAFKA-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586534#comment-16586534 ] David van Geest commented on KAFKA-6706: We also noticed this regression once we updated to 1.0.1

[jira] [Commented] (KAFKA-6763) Consider using direct byte buffers in SslTransportLayer

[ https://issues.apache.org/jira/browse/KAFKA-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586531#comment-16586531 ] Ismael Juma commented on KAFKA-6763: Yes, that's right [~leogomes]. One option is to simply run the

[jira] [Updated] (KAFKA-7314) MirrorMaker example in documentation does not work

[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7314: -- Component/s: mirrormaker > MirrorMaker example in documentation does not work >

[jira] [Updated] (KAFKA-7282) Failed to read `log header` from file channel

[ https://issues.apache.org/jira/browse/KAFKA-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7282: -- Component/s: log > Failed to read `log header` from file channel >

[jira] [Updated] (KAFKA-6763) Consider using direct byte buffers in SslTransportLayer

[ https://issues.apache.org/jira/browse/KAFKA-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6763: -- Component/s: network > Consider using direct byte buffers in SslTransportLayer >

[jira] [Updated] (KAFKA-7310) Fix SSL tests when running with Java 11

[ https://issues.apache.org/jira/browse/KAFKA-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7310: -- Component/s: unit tests packaging > Fix SSL tests when running with Java 11 >

[jira] [Updated] (KAFKA-7232) Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it

[ https://issues.apache.org/jira/browse/KAFKA-7232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7232: -- Component/s: tools > Allow kafka-topics.sh to take brokerid as parameter to show partitions >

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586476#comment-16586476 ] Jordan Moore commented on KAFKA-7315: - Thanks for opening [~vvcephei] Thoughts: List out the

[jira] [Commented] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

[ https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586472#comment-16586472 ] ASF GitHub Bot commented on KAFKA-6312: --- hachikuji closed pull request #4527: KAFKA-6312 Add

[jira] [Created] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

John Roesler created KAFKA-7315: --- Summary: Streams serialization docs contain a broken link for Avro Key: KAFKA-7315 URL: https://issues.apache.org/jira/browse/KAFKA-7315 Project: Kafka Issue

[jira] [Updated] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated KAFKA-7304: --- Affects Version/s: 1.1.1 > memory leakage in org.apache.kafka.common.network.Selector >

[jira] [Resolved] (KAFKA-7311) Sender should reset next batch expiry time between poll loops

[ https://issues.apache.org/jira/browse/KAFKA-7311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7311. -- Resolution: Fixed > Sender should reset next batch expiry time between poll loops >

[jira] [Updated] (KAFKA-7314) MirrorMaker example in documentation does not work

[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Wilkinson updated KAFKA-7314: -- Description: Kafka MirrorMaker as described in the documentation 

[jira] [Updated] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7278: Fix Version/s: 2.1.0 1.1.2 > replaceSegments() should not call asyncDeleteSegment() for

[jira] [Created] (KAFKA-7314) MirrorMaker example in documentation does not work

John Wilkinson created KAFKA-7314: - Summary: MirrorMaker example in documentation does not work Key: KAFKA-7314 URL: https://issues.apache.org/jira/browse/KAFKA-7314 Project: Kafka Issue

[jira] [Commented] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586362#comment-16586362 ] ASF GitHub Bot commented on KAFKA-7278: --- lindong28 opened a new pull request #5535: Cherry-pick

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586359#comment-16586359 ] Jason Gustafson commented on KAFKA-7190: Posted a KIP here:

[jira] [Commented] (KAFKA-7298) Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer

[ https://issues.apache.org/jira/browse/KAFKA-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586339#comment-16586339 ] Matthias J. Sax commented on KAFKA-7298: [~hachikuji] Should this be back ported to older

[jira] [Resolved] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7278. Resolution: Fixed Fix Version/s: 2.0.1 > replaceSegments() should not call

[jira] [Commented] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586320#comment-16586320 ] ASF GitHub Bot commented on KAFKA-7278: --- hachikuji closed pull request #5491: KAFKA-7278;

[jira] [Commented] (KAFKA-7303) Kafka client is stuck when specifying wrong brokers

[ https://issues.apache.org/jira/browse/KAFKA-7303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586255#comment-16586255 ] Chun Zhang commented on KAFKA-7303: --- Thanks Manikumar. I will give it a try with 2.0 This bug is

[jira] [Resolved] (KAFKA-7303) Kafka client is stuck when specifying wrong brokers

[ https://issues.apache.org/jira/browse/KAFKA-7303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun Zhang resolved KAFKA-7303. --- Resolution: Duplicate > Kafka client is stuck when specifying wrong brokers >

[jira] [Updated] (KAFKA-7313) KAFKA-7313; StopReplicaRequest should attempt to remove future replica for the partition only if future replica exists

[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7313: Description: This patch fixes two issues: 1) Currently if a broker received StopReplicaRequest with

[jira] [Updated] (KAFKA-7313) KAFKA-7313; StopReplicaRequest should attempt to remove future replica for the partition only if future replica exists

[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7313: Description: This patch fixes two issues:   1) Currently if a broker received StopReplicaRequest with

[jira] [Updated] (KAFKA-7313) KAFKA-7313; StopReplicaRequest should attempt to remove future replica for the partition only if future replica exists

[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7313: Summary: KAFKA-7313; StopReplicaRequest should attempt to remove future replica for the partition only if

[jira] [Resolved] (KAFKA-6835) Enable topic unclean leader election to be enabled without controller change

[ https://issues.apache.org/jira/browse/KAFKA-6835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-6835. Resolution: Fixed Merged the PR to trunk. > Enable topic unclean leader election to be enabled without

[jira] [Commented] (KAFKA-6835) Enable topic unclean leader election to be enabled without controller change

[ https://issues.apache.org/jira/browse/KAFKA-6835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586204#comment-16586204 ] ASF GitHub Bot commented on KAFKA-6835: --- junrao closed pull request #4957: KAFKA-6835: Enable topic

[jira] [Resolved] (KAFKA-7210) Add system test for log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7210. Resolution: Fixed > Add system test for log compaction > -- > >

[jira] [Commented] (KAFKA-7210) Add system test for log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585776#comment-16585776 ] ASF GitHub Bot commented on KAFKA-7210: --- ijuma closed pull request #5226: KAFKA-7210: Add a system

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585748#comment-16585748 ] Julien Debon commented on KAFKA-4740: - [~rocketraman] From the look of it, it is not possible today

[jira] [Commented] (KAFKA-960) Upgrade Metrics to 3.x

[ https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585713#comment-16585713 ] Erik van Oosten commented on KAFKA-960: --- Metrics 4.x was released not so long ago. The core is

[jira] [Commented] (KAFKA-7313) StopReplicaRequest should not remove partition from ReplicaManager.allPartitions if the replica is offline

[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585513#comment-16585513 ] ASF GitHub Bot commented on KAFKA-7313: --- lindong28 opened a new pull request #5533: KAFKA-7313;