[jira] [Commented] (KAFKA-9724) Consumer wrongly ignores fetched records "since it no longer has valid position"

[ https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071586#comment-17071586 ] Oleg Muravskiy commented on KAFKA-9724: --- Here's the bigger fragment of a log: [^co

[jira] [Updated] (KAFKA-9724) Consumer wrongly ignores fetched records "since it no longer has valid position"

[ https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Muravskiy updated KAFKA-9724: -- Attachment: consumer.log.xz > Consumer wrongly ignores fetched records "since it no longer has

[jira] [Resolved] (KAFKA-9789) if one machine has four broker, i want three is cluster ,how do ?

[ https://issues.apache.org/jira/browse/KAFKA-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sönke Liebau resolved KAFKA-9789. - Resolution: Not A Bug Hi [~startjava], this jira is to track bugs related to Kafka, for questio

[jira] [Commented] (KAFKA-9724) Consumer wrongly ignores fetched records "since it no longer has valid position"

[ https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071643#comment-17071643 ] Oleg Muravskiy commented on KAFKA-9724: --- The algorithm of a consumer is fairly simp

[jira] [Commented] (KAFKA-3720) Remove BufferExhaustException from doSend() in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071749#comment-17071749 ] Sönke Liebau commented on KAFKA-3720: - I read through the comments on the PR and woul

[jira] [Created] (KAFKA-9790) Wrong metric bean name for connect worker metrics

Alexandre YANG created KAFKA-9790: - Summary: Wrong metric bean name for connect worker metrics Key: KAFKA-9790 URL: https://issues.apache.org/jira/browse/KAFKA-9790 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9790) Wrong metric bean name for connect worker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre YANG updated KAFKA-9790: -- Attachment: image-2020-03-31-15-16-37-573.png > Wrong metric bean name for connect worker metri

[jira] [Updated] (KAFKA-9790) Wrong metric bean name for connect worker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre YANG updated KAFKA-9790: -- Description: The connect worker metrics implemented here:  * [https://github.com/apache/kafka/

[jira] [Updated] (KAFKA-9790) Wrong metric bean name for connect worker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre YANG updated KAFKA-9790: -- Description: The connect worker metrics implemented here:  * [https://github.com/apache/kafka/

[jira] [Updated] (KAFKA-9790) Wrong metric bean name for connect worker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre YANG updated KAFKA-9790: -- Description: The connect worker metrics implemented here:  * [https://github.com/apache/kafka/

[jira] [Updated] (KAFKA-9790) Wrong metric bean name for connect worker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre YANG updated KAFKA-9790: -- Environment: Tested with this docker image: cnfldemos/cp-server-connect-datagen:0.2.0-5.4.0 (

[jira] [Commented] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071883#comment-17071883 ] ASF GitHub Bot commented on KAFKA-8107: --- dajac commented on pull request #8394: KAF

[jira] [Commented] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071902#comment-17071902 ] Matthias J. Sax commented on KAFKA-9783: [~vvcephei] Does it fail locally for you

[jira] [Commented] (KAFKA-9757) Add documentation change for KIP-535

[ https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071906#comment-17071906 ] Navinder Brar commented on KAFKA-9757: -- Opened a PR for this: [https://github.com/ap

[jira] [Commented] (KAFKA-9746) MM2 produces messages in the wrong cluster

[ https://issues.apache.org/jira/browse/KAFKA-9746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071927#comment-17071927 ] Ryanne Dolan commented on KAFKA-9746: - This is because MM2 hands off records to Conne

[jira] [Commented] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071938#comment-17071938 ] John Roesler commented on KAFKA-9783: - I've just run it 90 times in a row, and it nev

[jira] [Updated] (KAFKA-9776) Producer should automatically downgrade TxnOffsetCommitRequest

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Affects Version/s: (was: 2.5.0) 2.6.0 > Producer should automatically down

[jira] [Updated] (KAFKA-9776) Producer could automatically downgrade TxnOffsetCommitRequest with internal flag

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Summary: Producer could automatically downgrade TxnOffsetCommitRequest with internal flag (was: Prod

[jira] [Updated] (KAFKA-9776) Producer could automatically downgrade TxnOffsetCommitRequest with internal flag

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Parent: KAFKA-8587 Issue Type: Sub-task (was: Improvement) > Producer could automatically do

[jira] [Commented] (KAFKA-9754) Trogdor workloads fail because topics are not fully created when workloads start.

[ https://issues.apache.org/jira/browse/KAFKA-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072032#comment-17072032 ] ASF GitHub Bot commented on KAFKA-9754: --- scott-hendricks commented on pull request

[jira] [Updated] (KAFKA-9766) Suppress detailed responses for security-sensitive (PCI-DSS) environments

[ https://issues.apache.org/jira/browse/KAFKA-9766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-9766: - Labels: Needs-kip (was: ) > Suppress detailed responses for security-sensitive (PCI-DSS) environ

[jira] [Updated] (KAFKA-9752) Consumer rebalance can be stuck after new member timeout with old JoinGroup version

[ https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9752: --- Description: For older versions of the JoinGroup protocol (v3 and below), there was no way f

[jira] [Commented] (KAFKA-3720) Remove BufferExhaustException from doSend() in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072089#comment-17072089 ] Mayuresh Gharat commented on KAFKA-3720: You can take this up. Thanks, Mayuresh

[jira] [Commented] (KAFKA-9750) Flaky test kafka.server.ReplicaManagerTest.testFencedErrorCausedByBecomeLeader

[ https://issues.apache.org/jira/browse/KAFKA-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072092#comment-17072092 ] David Arthur commented on KAFKA-9750: - [~hachikuji] are we still considering this a b

[jira] [Commented] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072186#comment-17072186 ] Matthias J. Sax commented on KAFKA-9783: If it passed locally isn't it not flaky

[jira] [Created] (KAFKA-9791) Streams should log the effective RocksDB configuration when opening a database

John Roesler created KAFKA-9791: --- Summary: Streams should log the effective RocksDB configuration when opening a database Key: KAFKA-9791 URL: https://issues.apache.org/jira/browse/KAFKA-9791 Project: K

[jira] [Commented] (KAFKA-3720) Remove BufferExhaustException from doSend() in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072225#comment-17072225 ] ASF GitHub Bot commented on KAFKA-3720: --- soenkeliebau commented on pull request #83

[jira] [Commented] (KAFKA-3720) Remove BufferExhaustException from doSend() in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072230#comment-17072230 ] Sönke Liebau commented on KAFKA-3720: - Thanks [~mgharat] I've created a new pull req

[jira] [Commented] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072232#comment-17072232 ] Matthias J. Sax commented on KAFKA-9783: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072233#comment-17072233 ] Matthias J. Sax commented on KAFKA-8264: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9753) Add task-level active-process-ratio to Streams metrics

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

[jira] [Resolved] (KAFKA-9753) Add task-level active-process-ratio to Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-9753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9753. -- Fix Version/s: 2.6.0 Resolution: Fixed > Add task-level active-process-ratio to Streams

[jira] [Resolved] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

[ https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5842. -- Resolution: Fixed Hopefully it has fixed via https://github.com/apache/kafka/pull/8370 > Query

[jira] [Resolved] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9783. -- Fix Version/s: 2.6.0 Resolution: Fixed I think https://github.com/apache/kafka/pull/8370

[jira] [Commented] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072255#comment-17072255 ] ASF GitHub Bot commented on KAFKA-9739: --- bbejeck commented on pull request #8400: K

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072259#comment-17072259 ] GEORGE LI commented on KAFKA-4084: -- [~blodsbror] Very busy with work and this COVID-19

[jira] [Updated] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9739: --- Affects Version/s: 2.3.0 2.4.0 > StreamsBuilder.build fails with StreamsExcept

[jira] [Updated] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9739: --- Fix Version/s: 2.5.1 2.4.2 2.6.0 2.3.2 > Str

[jira] [Commented] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072260#comment-17072260 ] Bill Bejeck commented on KAFKA-9739: [~apoli] I've submitted a PR with the fix.  A de

[jira] [Updated] (KAFKA-9740) Add a "continue" option for Kafka Connect error handling

[ https://issues.apache.org/jira/browse/KAFKA-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zihan Li updated KAFKA-9740: Description: Currently there are two error handling options in Kafka Connect, "none" and "all". Option "no

[jira] [Commented] (KAFKA-9740) Add a "continue" option for Kafka Connect error handling

[ https://issues.apache.org/jira/browse/KAFKA-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072323#comment-17072323 ] ASF GitHub Bot commented on KAFKA-9740: --- lizihan021 commented on pull request #8401

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072341#comment-17072341 ] Matthias J. Sax commented on KAFKA-8677: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072342#comment-17072342 ] ASF GitHub Bot commented on KAFKA-9441: --- mjsax commented on pull request #8356: KAF

[jira] [Created] (KAFKA-9792) Improve sticky task assignment for previous active tasks

Sophie Blee-Goldman created KAFKA-9792: -- Summary: Improve sticky task assignment for previous active tasks Key: KAFKA-9792 URL: https://issues.apache.org/jira/browse/KAFKA-9792 Project: Kafka

[jira] [Created] (KAFKA-9793) Stream HandleAssignment should guarantee task close

Boyang Chen created KAFKA-9793: -- Summary: Stream HandleAssignment should guarantee task close Key: KAFKA-9793 URL: https://issues.apache.org/jira/browse/KAFKA-9793 Project: Kafka Issue Type: Imp

[jira] [Updated] (KAFKA-9793) Stream HandleAssignment should guarantee task close

[ https://issues.apache.org/jira/browse/KAFKA-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9793: --- Affects Version/s: 2.6.0 > Stream HandleAssignment should guarantee task close >

[jira] [Updated] (KAFKA-9793) Stream HandleAssignment should guarantee task close

[ https://issues.apache.org/jira/browse/KAFKA-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9793: --- Issue Type: Bug (was: Improvement) > Stream HandleAssignment should guarantee task close > -

[jira] [Commented] (KAFKA-9793) Stream HandleAssignment should guarantee task close

[ https://issues.apache.org/jira/browse/KAFKA-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072392#comment-17072392 ] ASF GitHub Bot commented on KAFKA-9793: --- abbccdda commented on pull request #8402:

[jira] [Commented] (KAFKA-9746) MM2 produces messages in the wrong cluster

[ https://issues.apache.org/jira/browse/KAFKA-9746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072404#comment-17072404 ] Marcel Renders commented on KAFKA-9746: --- [~ryannedolan] thanks for your answer. I u

[jira] [Updated] (KAFKA-3720) Remove BufferExhaustedException from doSend() in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-3720: -- Summary: Remove BufferExhaustedException from doSend() in KafkaProducer (was: Remove BufferExh

[jira] [Created] (KAFKA-9794) JMX metrics produce higher memory and CPU consumption in Kafka docker

Hariprasad created KAFKA-9794: - Summary: JMX metrics produce higher memory and CPU consumption in Kafka docker Key: KAFKA-9794 URL: https://issues.apache.org/jira/browse/KAFKA-9794 Project: Kafka

[jira] [Commented] (KAFKA-6037) Make Sub-topology Parallelism Tunable

[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072412#comment-17072412 ] Matthias J. Sax commented on KAFKA-6037: [~guozhang] Do you think this ticket is