[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&focusedCommentId=16585513#comment-16585513 ] ASF GitHub Bot commented on KAFKA-7313: --- lindong28 opened a new pull request #5533:

[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&focusedCommentId=16585713#comment-16585713 ] Erik van Oosten commented on KAFKA-960: --- Metrics 4.x was released not so long ago. T

[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&focusedCommentId=16585748#comment-16585748 ] Julien Debon commented on KAFKA-4740: - [~rocketraman] From the look of it, it is not

[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&focusedCommentId=16585776#comment-16585776 ] ASF GitHub Bot commented on KAFKA-7210: --- ijuma closed pull request #5226: KAFKA-721

[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-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&focusedCommentId=16586140#comment-16586140 ] ASF GitHub Bot commented on KAFKA-7298: --- hachikuji closed pull request #5518: KAFKA

[jira] [Resolved] (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:all-tabpanel ] Jason Gustafson resolved KAFKA-7298. Resolution: Fixed Fix Version/s: 2.0.1 > Concurrent DeleteRecords can lead to fatal

[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&focusedCommentId=16586204#comment-16586204 ] ASF GitHub Bot commented on KAFKA-6835: --- junrao closed pull request #4957: KAFKA-68

[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 con

[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 f

[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 del

[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 delete

[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] [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&focusedCommentId=16586255#comment-16586255 ] Chun Zhang commented on KAFKA-7303: --- Thanks Manikumar. I will give it a try with 2.0 T

[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&focusedCommentId=16586320#comment-16586320 ] ASF GitHub Bot commented on KAFKA-7278: --- hachikuji closed pull request #5491: KAFKA

[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 asyncDele

[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&focusedCommentId=16586339#comment-16586339 ] Matthias J. Sax commented on KAFKA-7298: [~hachikuji] Should this be back ported

[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&focusedCommentId=16586359#comment-16586359 ] Jason Gustafson commented on KAFKA-7190: Posted a KIP here: https://cwiki.apache

[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&focusedCommentId=16586362#comment-16586362 ] ASF GitHub Bot commented on KAFKA-7278: --- lindong28 opened a new pull request #5535:

[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 Type

[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] [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  [here|https://kafka.apache.or

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16586405#comment-16586405 ] ASF GitHub Bot commented on KAFKA-7311: --- guozhangwang closed pull request #5531: KA

[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-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] [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 T

[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&focusedCommentId=16586472#comment-16586472 ] ASF GitHub Bot commented on KAFKA-6312: --- hachikuji closed pull request #4527: KAFKA

[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&focusedCommentId=16586476#comment-16586476 ] Jordan Moore commented on KAFKA-7315: - Thanks for opening [~vvcephei] Thoughts: Lis

[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 > associat

[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-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-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-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] [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&focusedCommentId=16586531#comment-16586531 ] Ismael Juma commented on KAFKA-6763: Yes, that's right [~leogomes]. One option is to

[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&focusedCommentId=16586534#comment-16586534 ] David van Geest commented on KAFKA-6706: We also noticed this regression once we

[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&focusedCommentId=16586573#comment-16586573 ] ASF GitHub Bot commented on KAFKA-5891: --- rayokota opened a new pull request #5537:

[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] [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-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-7307) Upgrade EasyMock for Java 11 support

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

[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-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-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-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-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-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-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-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-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-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-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-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-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 > cle

[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&focusedCommentId=16586615#comment-16586615 ] Jiangtao Liu commented on KAFKA-6961: - I encounter the same issue after I move Kafka

[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&focusedCommentId=16586619#comment-16586619 ] Matthias J. Sax commented on KAFKA-7315: Personally, I think the docs should be v

[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&focusedCommentId=16586629#comment-16586629 ] Jordan Moore commented on KAFKA-7315: - bq. should be vendor agnostic and not mention

[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&focusedCommentId=16586629#comment-16586629 ] Jordan Moore edited comment on KAFKA-7315 at 8/20/18 10:56 PM:

[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&focusedCommentId=16586635#comment-16586635 ] Matthias J. Sax commented on KAFKA-7315: It's just my personal thought :) (I like

[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&focusedCommentId=16586615#comment-16586615 ] Jiangtao Liu edited comment on KAFKA-6961 at 8/20/18 11:08 PM:

[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&focusedCommentId=16586650#comment-16586650 ] Jordan Moore commented on KAFKA-7315: - What about a separate section on SerDe's outsi

[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&focusedCommentId=16586650#comment-16586650 ] Jordan Moore edited comment on KAFKA-7315 at 8/20/18 11:12 PM:

[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&focusedCommentId=16586665#comment-16586665 ] ASF GitHub Bot commented on KAFKA-5891: --- hachikuji closed pull request #4633: KAFKA

[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 1.

[jira] [Created] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

Matthias J. Sax created KAFKA-7317: -- Summary: Use collections subscription for main consumer to reduce metadata Key: KAFKA-7317 URL: https://issues.apache.org/jira/browse/KAFKA-7317 Project: Kafka

[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] [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] [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 StackOverflowEr

[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 StackOverflowErro

[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&focusedCommentId=16586709#comment-16586709 ] Matthias J. Sax commented on KAFKA-7315: `Serde` are a Streams concept – it's an

[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&focusedCommentId=16586738#comment-16586738 ] Ted Yu commented on KAFKA-7316: --- I was thinking about removing the implicit wrapKTable . Th

[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&focusedCommentId=16586841#comment-16586841 ] Ted Yu commented on KAFKA-7316: --- [~guozhang] [~mjsax] : Can you take a look at patch v1 to

[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&focusedCommentId=16586886#comment-16586886 ] lambdaliu commented on KAFKA-7190: -- Hi [~hachikuji], sorry for the later reply. I have

[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-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&focusedCommentId=16586897#comment-16586897 ] Ted Yu commented on KAFKA-7316: --- Patch v2 reduces compilation errors to 20. > Use of filte

[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&focusedCommentId=16586903#comment-16586903 ] lambdaliu commented on KAFKA-7190: -- Hi [~mjsax], Changing the log level to DEBUG can't a

[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-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&focusedCommentId=16586909#comment-16586909 ] Ted Yu commented on KAFKA-7316: --- Patch v4 makes the code compile. > Use of filter method i

[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&focusedCommentId=16586927#comment-16586927 ] ASF GitHub Bot commented on KAFKA-7316: --- tedyu opened a new pull request #5543: KAF

[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&focusedCommentId=16586938#comment-16586938 ] Nikolay Izhikov commented on KAFKA-7277: Hello, [~vvcephei]. I've addressed all

[jira] [Created] (KAFKA-7318) Should introduce a offset reset policy to consume only the messages after subscribing

joechen8...@gmail.com created KAFKA-7318: Summary: Should introduce a offset reset policy to consume only the messages after subscribing Key: KAFKA-7318 URL: https://issues.apache.org/jira/browse/KAFKA-731

[jira] [Updated] (KAFKA-7318) Should introduce a offset reset policy to consume only the messages after subscribing

[ https://issues.apache.org/jira/browse/KAFKA-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] joechen8...@gmail.com updated KAFKA-7318: - Description: On our situation, we want the consumers only consume the messages wh