[jira] [Resolved] (KAFKA-9834) Add interface to set ZSTD compresson level

[ https://issues.apache.org/jira/browse/KAFKA-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiamei xie resolved KAFKA-9834. --- Resolution: Duplicate Duplicate with KAFKA-7632 > Add interface to set ZSTD compresson level > -

[jira] [Commented] (KAFKA-9834) Add interface to set ZSTD compresson level

[ https://issues.apache.org/jira/browse/KAFKA-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083819#comment-17083819 ] jiamei xie commented on KAFKA-9834: --- Ok. I'll close this jira. > Add interface to set

[jira] [Resolved] (KAFKA-9826) Log cleaning repeatedly picks same segment with no effect when first dirty offset is past start of active segment

[ https://issues.apache.org/jira/browse/KAFKA-9826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-9826. Fix Version/s: 2.6.0 Resolution: Fixed merged the PR to trunk > Log cleaning repeatedly picks same

[jira] [Commented] (KAFKA-9826) Log cleaning repeatedly picks same segment with no effect when first dirty offset is past start of active segment

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

[jira] [Created] (KAFKA-9871) Consumer group description showing duplicate partition information

OM Singh created KAFKA-9871: --- Summary: Consumer group description showing duplicate partition information Key: KAFKA-9871 URL: https://issues.apache.org/jira/browse/KAFKA-9871 Project: Kafka Issue

[jira] [Updated] (KAFKA-9870) Error is reported until the cluster is restarted. Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: T

[ https://issues.apache.org/jira/browse/KAFKA-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yonglu gao updated KAFKA-9870: -- Description: I have a kafka cluster .when broker 2 restart,then error,Error is reported until the clus

[jira] [Created] (KAFKA-9870) Error is reported until the cluster is restarted. Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: T

yonglu gao created KAFKA-9870: - Summary: Error is reported until the cluster is restarted. Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that

[jira] [Updated] (KAFKA-9869) kafka offset is discontinuous when appear when appear EOFException

[ https://issues.apache.org/jira/browse/KAFKA-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee chen updated KAFKA-9869: Description: My kafka version is 0.11.x .The producer I used add the config conpression.type = gzip,

[jira] [Updated] (KAFKA-9869) kafka offset is discontinuous when appear when appear EOFException

[ https://issues.apache.org/jira/browse/KAFKA-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee chen updated KAFKA-9869: Description: My kafka version is 0.11.x .The producer I used add the config conpression.type = gzip,

[jira] [Created] (KAFKA-9869) kafka offset is discontinuous when appear when appear EOFException

Lee chen created KAFKA-9869: --- Summary: kafka offset is discontinuous when appear when appear EOFException Key: KAFKA-9869 URL: https://issues.apache.org/jira/browse/KAFKA-9869 Project: Kafka Iss

[jira] [Commented] (KAFKA-9857) Failed to build image ducker-ak-openjdk-8 on arm

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

[jira] [Commented] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology

[ https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083736#comment-17083736 ] Bill Bejeck commented on KAFKA-9298: In Investigating this more to nail down when thi

[jira] [Commented] (KAFKA-9819) Flaky Test StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0]

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

[jira] [Commented] (KAFKA-8611) Add KStream#repartition operation

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

[jira] [Commented] (KAFKA-8079) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest#shouldSurviveFastLeaderChange

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

[jira] [Resolved] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5676. Resolution: Fixed > MockStreamsMetrics should be in o.a.k.test > --

[jira] [Reopened] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5676: > MockStreamsMetrics should be in o.a.k.test > -- > >

[jira] [Updated] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8856: --- Fix Version/s: 2.4.0 > Add Streams Config for Backward-compatible Metrics > -

[jira] [Updated] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8179: --- Fix Version/s: (was: 2.5.0) > Incremental Rebalance Protocol for Kafka Consumer > ---

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083707#comment-17083707 ] Matthias J. Sax commented on KAFKA-9831: Thanks [~ableegoldman]. Will investigate

[jira] [Updated] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

[ https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9868: --- Component/s: unit tests > Flaky Test > EOSUncleanShutdownIntegrationTest.shouldWorkWithUncle

[jira] [Resolved] (KAFKA-7544) Transient Failure: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails

[ https://issues.apache.org/jira/browse/KAFKA-7544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7544. Resolution: Duplicate Closing this ticket as it links to the older, non-parameterized versi

[jira] [Commented] (KAFKA-9867) Log cleaner throws InvalidOffsetException for some partitions

[ https://issues.apache.org/jira/browse/KAFKA-9867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083661#comment-17083661 ] Bradley Peterson commented on KAFKA-9867: - I haven't. I didn't see any related ch

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

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

[jira] [Created] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

Sophie Blee-Goldman created KAFKA-9868: -- Summary: Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore Key: KAFKA-9868 URL: https://issues.apache.org/jira/browse/KAFKA-9

[jira] [Commented] (KAFKA-9867) Log cleaner throws InvalidOffsetException for some partitions

[ https://issues.apache.org/jira/browse/KAFKA-9867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083647#comment-17083647 ] Ismael Juma commented on KAFKA-9867: Thanks for the report. Have you tried 2.4.1? >

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083598#comment-17083598 ] Sophie Blee-Goldman commented on KAFKA-9831: I don't think either of the bugs

[jira] [Created] (KAFKA-9867) Log cleaner throws InvalidOffsetException for some partitions

Bradley created KAFKA-9867: -- Summary: Log cleaner throws InvalidOffsetException for some partitions Key: KAFKA-9867 URL: https://issues.apache.org/jira/browse/KAFKA-9867 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9866) Do not attempt to elect preferred leader replicas which are outside ISR

Stanislav Kozlovski created KAFKA-9866: -- Summary: Do not attempt to elect preferred leader replicas which are outside ISR Key: KAFKA-9866 URL: https://issues.apache.org/jira/browse/KAFKA-9866 Pro

[jira] [Commented] (KAFKA-9862) Enable --if-exists and --if-not-exists for AdminClient in TopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083525#comment-17083525 ] Cheng Tan commented on KAFKA-9862: -- Thanks. I put critical because it blocks the --zooke

[jira] [Updated] (KAFKA-9862) Enable --if-exists and --if-not-exists for AdminClient in TopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cheng Tan updated KAFKA-9862: - Priority: Minor (was: Critical) > Enable --if-exists and --if-not-exists for AdminClient in TopicCommand

[jira] [Commented] (KAFKA-9539) Add leader epoch in StopReplicaRequest

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

[jira] [Resolved] (KAFKA-9539) Add leader epoch in StopReplicaRequest

[ https://issues.apache.org/jira/browse/KAFKA-9539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9539. Fix Version/s: 2.6.0 Resolution: Fixed > Add leader epoch in StopReplicaRequest > --

[jira] [Commented] (KAFKA-9858) CVE-2016-3189 Use-after-free vulnerability in bzip2recover in bzip2 1.0.6 allows remote attackers to cause a denial of service (crash) via a crafted bzip2 file, relate

[ https://issues.apache.org/jira/browse/KAFKA-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083482#comment-17083482 ] Guozhang Wang commented on KAFKA-9858: -- For rocksdbjni, I saw that at the moment eve

[jira] [Commented] (KAFKA-9840) Consumer should not use OffsetForLeaderEpoch without current epoch validation

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

[jira] [Commented] (KAFKA-9764) Deprecate Stream Simple benchmark

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

[jira] [Updated] (KAFKA-9865) Expose output topic names from TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-9865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9865: --- Issue Type: Improvement (was: Bug) > Expose output topic names from TopologyTestDriver > ---

[jira] [Updated] (KAFKA-9865) Expose output topic names from TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-9865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9865: --- Labels: kip (was: ) > Expose output topic names from TopologyTestDriver > --

[jira] [Assigned] (KAFKA-9864) Avoid expensive QuotaViolationException usage

[ https://issues.apache.org/jira/browse/KAFKA-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Bradstreet reassigned KAFKA-9864: --- Assignee: Lucas Bradstreet > Avoid expensive QuotaViolationException usage > ---

[jira] [Issue Comment Deleted] (KAFKA-9864) Avoid expensive QuotaViolationException usage

[ https://issues.apache.org/jira/browse/KAFKA-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9864: --- Comment: was deleted (was: big-andy-coates commented on pull request #8483: fixes: https://i

[jira] [Updated] (KAFKA-9865) Expose output topic names from TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-9865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Coates updated KAFKA-9865: --- Description: Expose the output topic names from TopologyTestDriver, i.e. `outputRecordsByTopic.keySe

[jira] [Assigned] (KAFKA-9865) Expose output topic names from TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-9865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Coates reassigned KAFKA-9865: -- Assignee: Andy Coates > Expose output topic names from TopologyTestDriver > --

[jira] [Assigned] (KAFKA-9864) Avoid expensive QuotaViolationException usage

[ https://issues.apache.org/jira/browse/KAFKA-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Coates reassigned KAFKA-9864: -- Assignee: (was: Andy Coates) > Avoid expensive QuotaViolationException usage > ---

[jira] [Issue Comment Deleted] (KAFKA-9864) Avoid expensive QuotaViolationException usage

[ https://issues.apache.org/jira/browse/KAFKA-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Coates updated KAFKA-9864: --- Comment: was deleted (was: Patch available: [https://github.com/apache/kafka/pull/8483]) > Avoid ex

[jira] [Commented] (KAFKA-9864) Avoid expensive QuotaViolationException usage

[ https://issues.apache.org/jira/browse/KAFKA-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083308#comment-17083308 ] Lucas Bradstreet commented on KAFKA-9864: - PR is available at [https://github.com

[jira] [Commented] (KAFKA-9864) Avoid expensive QuotaViolationException usage

[ https://issues.apache.org/jira/browse/KAFKA-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083300#comment-17083300 ] ASF GitHub Bot commented on KAFKA-9864: --- big-andy-coates commented on pull request

[jira] [Assigned] (KAFKA-9864) Avoid expensive QuotaViolationException usage

[ https://issues.apache.org/jira/browse/KAFKA-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Coates reassigned KAFKA-9864: -- Assignee: Andy Coates > Avoid expensive QuotaViolationException usage > --

[jira] [Created] (KAFKA-9865) Expose output topic names from TopologyTestDriver

Andy Coates created KAFKA-9865: -- Summary: Expose output topic names from TopologyTestDriver Key: KAFKA-9865 URL: https://issues.apache.org/jira/browse/KAFKA-9865 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-9864) Avoid expensive QuotaViolationException usage

Lucas Bradstreet created KAFKA-9864: --- Summary: Avoid expensive QuotaViolationException usage Key: KAFKA-9864 URL: https://issues.apache.org/jira/browse/KAFKA-9864 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9863) update the deprecated --zookeeper option in the documentation into --bootstrap-server

[ https://issues.apache.org/jira/browse/KAFKA-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-9863: - Description: Since V2.2.0, the -zookeeper option turned into deprecated because Kafka can directly conne

[jira] [Created] (KAFKA-9863) update the deprecated --zookeeper option in the documentation into --bootstrap-server

Luke Chen created KAFKA-9863: Summary: update the deprecated --zookeeper option in the documentation into --bootstrap-server Key: KAFKA-9863 URL: https://issues.apache.org/jira/browse/KAFKA-9863 Project:

[jira] [Commented] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

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

[jira] [Commented] (KAFKA-3346) Rename "Mode" to "SslMode"

[ https://issues.apache.org/jira/browse/KAFKA-3346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082977#comment-17082977 ] Chia-Ping Tsai commented on KAFKA-3346: --- Is this still available? ConnectionMode is

[jira] [Commented] (KAFKA-9862) Enable --if-exists and --if-not-exists for AdminClient in TopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082928#comment-17082928 ] Sönke Liebau commented on KAFKA-9862: - Hi [~d8tltanc], that sounds useful, thanks!