[jira] [Resolved] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7441. - Resolution: Fixed > Allow LogCleanerManager.resumeCleaning() to be used concurrently >

[jira] [Updated] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7196: Fix Version/s: (was: 2.2.0) 2.1.0 2.0.1 1.1.2

[jira] [Assigned] (KAFKA-7475) print the actual cluster bootstrap address on authentication failures

[ https://issues.apache.org/jira/browse/KAFKA-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-7475: --- Assignee: radai rosenblatt > print the actual cluster bootstrap address on authentication failures

[jira] [Updated] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5276: Fix Version/s: (was: 2.1.0) 2.2.0 > Support derived and prefixed configs in

[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=16636555#comment-16636555 ] Dong Lin commented on KAFKA-7149: - Added Navinder to contributor list and assigned Jira to Navinder. >

[jira] [Assigned] (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:all-tabpanel ] Dong Lin reassigned KAFKA-7149: --- Assignee: Navinder Brar (was: Ashish Surana) > Reduce assignment data size to improve kafka

[jira] [Updated] (KAFKA-4203) Java producer default max message size does not align with broker default

[ https://issues.apache.org/jira/browse/KAFKA-4203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4203: Fix Version/s: (was: 2.1.0) 2.2.0 > Java producer default max message size does not

[jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3554: Fix Version/s: (was: 2.1.0) 2.2.0 > Generate actual data with specific compression

[jira] [Updated] (KAFKA-4249) Document how to customize GC logging options for broker

[ https://issues.apache.org/jira/browse/KAFKA-4249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4249: Fix Version/s: (was: 2.1.0) 2.2.0 > Document how to customize GC logging options

[jira] [Updated] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3042: Fix Version/s: (was: 2.1.0) 2.2.0 > updateIsr should stop after failed several

[jira] [Updated] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout

[ https://issues.apache.org/jira/browse/KAFKA-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5792: Fix Version/s: (was: 2.1.0) 2.2.0 > Transient failure in

[jira] [Updated] (KAFKA-6774) Improve default groupId behavior in consumer

[ https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6774: Fix Version/s: (was: 2.1.0) 2.2.0 > Improve default groupId behavior in consumer >

[jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5722: Fix Version/s: (was: 2.1.0) 2.2.0 > Refactor ConfigCommand to use the AdminClient >

[jira] [Updated] (KAFKA-5272) Improve validation for Alter Configs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5272: Fix Version/s: (was: 2.1.0) 2.2.0 > Improve validation for Alter Configs (KIP-133)

[jira] [Updated] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7026: Fix Version/s: (was: 2.1.0) 2.2.0 > Sticky assignor could assign a partition to

[jira] [Updated] (KAFKA-5029) cleanup javadocs and logging

[ https://issues.apache.org/jira/browse/KAFKA-5029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5029: Fix Version/s: (was: 2.1.0) 2.2.0 > cleanup javadocs and logging >

[jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements

[ https://issues.apache.org/jira/browse/KAFKA-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3866: Fix Version/s: (was: 2.1.0) 2.2.0 > KerberosLogin refresh time bug and other

[jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5876: Fix Version/s: (was: 2.1.0) 2.2.0 > IQ should throw different exceptions for

[jira] [Updated] (KAFKA-7462) Kafka brokers cannot provide OAuth without a token

[ https://issues.apache.org/jira/browse/KAFKA-7462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7462: Fix Version/s: (was: 2.1.0) 2.2.0 > Kafka brokers cannot provide OAuth without a

[jira] [Updated] (KAFKA-7389) Upgrade spotBugs for Java 11 support

[ https://issues.apache.org/jira/browse/KAFKA-7389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7389: Fix Version/s: (was: 2.1.0) 2.2.0 > Upgrade spotBugs for Java 11 support >

[jira] [Resolved] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-7096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7096. - Resolution: Fixed > Consumer should drop the data for unassigned topic partitions >

[jira] [Updated] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-7096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7096: Fix Version/s: (was: 2.1.0) 2.2.0 > Consumer should drop the data for unassigned

[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 ] Dong Lin updated KAFKA-7307: Fix Version/s: (was: 2.1.0) 2.2.0 > Upgrade EasyMock for Java 11 support >

[jira] [Updated] (KAFKA-6880) Zombie replicas must be fenced

[ https://issues.apache.org/jira/browse/KAFKA-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6880: Fix Version/s: (was: 2.1.0) 2.2.0 > Zombie replicas must be fenced >

[jira] [Updated] (KAFKA-7383) Verify leader epoch in produce requests (KIP-359)

[ https://issues.apache.org/jira/browse/KAFKA-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7383: Fix Version/s: (was: 2.1.0) 2.2.0 > Verify leader epoch in produce requests

[jira] [Updated] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3821: Fix Version/s: (was: 2.1.0) 2.2.0 > Allow Kafka Connect source tasks to produce

[jira] [Updated] (KAFKA-7251) Add support for TLS 1.3

[ https://issues.apache.org/jira/browse/KAFKA-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7251: Fix Version/s: (was: 2.1.0) 2.2.0 > Add support for TLS 1.3 >

[jira] [Resolved] (KAFKA-6045) All access to log should fail if log is closed

[ https://issues.apache.org/jira/browse/KAFKA-6045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6045. - Resolution: Won't Fix > All access to log should fail if log is closed >

[jira] [Updated] (KAFKA-7264) Support Java 11

[ https://issues.apache.org/jira/browse/KAFKA-7264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7264: Fix Version/s: (was: 2.1.0) 2.2.0 > Support Java 11 > --- > >

[jira] [Updated] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6029: Fix Version/s: (was: 2.1.0) 2.2.0 > Controller should wait for the leader migration

[jira] [Updated] (KAFKA-5286) Producer should await transaction completion in close

[ https://issues.apache.org/jira/browse/KAFKA-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5286: Fix Version/s: (was: 2.1.0) 2.2.0 > Producer should await transaction completion in

[jira] [Updated] (KAFKA-1120) Controller could miss a broker state change

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1120: Fix Version/s: (was: 2.1.0) 2.2.0 > Controller could miss a broker state change >

[jira] [Commented] (KAFKA-5347) OutOfSequence error should be fatal

[ https://issues.apache.org/jira/browse/KAFKA-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636544#comment-16636544 ] Dong Lin commented on KAFKA-5347: - Moving this to 2.2.0 since there is no PR ready. > OutOfSequence

[jira] [Updated] (KAFKA-5347) OutOfSequence error should be fatal

[ https://issues.apache.org/jira/browse/KAFKA-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5347: Fix Version/s: (was: 2.1.0) 2.2.0 > OutOfSequence error should be fatal >

[jira] [Updated] (KAFKA-5527) Idempotent/transactional Producer part 2 (KIP-98)

[ https://issues.apache.org/jira/browse/KAFKA-5527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5527: Fix Version/s: (was: 2.1.0) 2.2.0 > Idempotent/transactional Producer part 2

[jira] [Updated] (KAFKA-5964) Add more unit tests for SslTransportLayer

[ https://issues.apache.org/jira/browse/KAFKA-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5964: Fix Version/s: (was: 2.1.0) 2.2.0 > Add more unit tests for SslTransportLayer >

[jira] [Updated] (KAFKA-5782) Avoid unnecessary PID reset when expire batches.

[ https://issues.apache.org/jira/browse/KAFKA-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5782: Fix Version/s: (was: 2.1.0) 2.2.0 > Avoid unnecessary PID reset when expire

[jira] [Updated] (KAFKA-5834) AbstractConfig.logUnused() may log confusing warning information.

[ https://issues.apache.org/jira/browse/KAFKA-5834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5834: Fix Version/s: (was: 2.1.0) 2.2.0 > AbstractConfig.logUnused() may log confusing

[jira] [Resolved] (KAFKA-5950) AdminClient should retry based on returned error codes

[ https://issues.apache.org/jira/browse/KAFKA-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5950. - Resolution: Fixed Per comment in the PR, it appears that the issue has been addressed in KAFKA-6299

[jira] [Updated] (KAFKA-5950) AdminClient should retry based on returned error codes

[ https://issues.apache.org/jira/browse/KAFKA-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5950: Fix Version/s: (was: 2.1.0) 2.2.0 > AdminClient should retry based on returned

[jira] [Resolved] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5857. - Resolution: Cannot Reproduce In general we need heapdump to investigate the issue. Since we don't have

[jira] [Updated] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned

[ https://issues.apache.org/jira/browse/KAFKA-6304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6304: Fix Version/s: (was: 2.1.0) 2.2.0 > The controller should allow updating the

[jira] [Updated] (KAFKA-7198) Enhance KafkaStreams start method javadoc

[ https://issues.apache.org/jira/browse/KAFKA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7198: Fix Version/s: (was: 2.1.0) 2.2.0 > Enhance KafkaStreams start method javadoc >

[jira] [Updated] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions

[ https://issues.apache.org/jira/browse/KAFKA-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7051: Fix Version/s: (was: 2.1.0) 2.2.0 > Improve the efficiency of the ReplicaManager

[jira] [Updated] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap

[ https://issues.apache.org/jira/browse/KAFKA-5693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5693: Fix Version/s: (was: 2.1.0) 2.2.0 > TopicCreationPolicy and AlterConfigsPolicy

[jira] [Updated] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5532: Fix Version/s: (was: 2.1.0) 2.2.0 > Making bootstrap.servers property a first

[jira] [Updated] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4125: Fix Version/s: (was: 2.1.0) 2.2.0 > Provide low-level Processor API meta data in

[jira] [Updated] (KAFKA-4693) Consumer subscription change during rebalance causes exception

[ https://issues.apache.org/jira/browse/KAFKA-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4693: Fix Version/s: (was: 2.1.0) 2.2.0 > Consumer subscription change during rebalance

[jira] [Updated] (KAFKA-7266) Fix MetricsTest test flakiness

[ https://issues.apache.org/jira/browse/KAFKA-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7266: Fix Version/s: (was: 2.0.1) (was: 2.1.0) 2.2.0 > Fix

[jira] [Updated] (KAFKA-7259) Remove deprecated ZKUtils usage from ZkSecurityMigrator

[ https://issues.apache.org/jira/browse/KAFKA-7259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7259: Fix Version/s: (was: 2.1.0) 2.2.0 > Remove deprecated ZKUtils usage from

[jira] [Updated] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7196: Fix Version/s: (was: 2.1.0) 2.2.0 > Remove heartbeat delayed operation for those

[jira] [Updated] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3596: Fix Version/s: (was: 2.1.0) 2.2.0 > Kafka Streams: Window expiration needs to

[jira] [Updated] (KAFKA-7377) update metrics module from yammer to dropwizrd

[ https://issues.apache.org/jira/browse/KAFKA-7377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7377: Fix Version/s: (was: 1.1.2) (was: 2.0.1) (was: 1.0.3)

[jira] [Updated] (KAFKA-5214) Re-add KafkaAdminClient#apiVersions

[ https://issues.apache.org/jira/browse/KAFKA-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5214: Fix Version/s: (was: 2.1.0) 2.2.0 > Re-add KafkaAdminClient#apiVersions >

[jira] [Updated] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5692: Fix Version/s: (was: 2.1.0) 2.2.0 > Refactor PreferredReplicaLeaderElectionCommand

[jira] [Updated] (KAFKA-3575) Use console consumer access topic that does not exist, can not use "Control + C" to exit process

[ https://issues.apache.org/jira/browse/KAFKA-3575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3575: Fix Version/s: (was: 2.1.0) 2.2.0 > Use console consumer access topic that does not

[jira] [Updated] (KAFKA-3733) Avoid long command lines by setting CLASSPATH in environment

[ https://issues.apache.org/jira/browse/KAFKA-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3733: Fix Version/s: (was: 2.1.0) 2.2.0 > Avoid long command lines by setting CLASSPATH

[jira] [Updated] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size (KIP-264)

[ https://issues.apache.org/jira/browse/KAFKA-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3999: Fix Version/s: (was: 2.1.0) 2.2.0 > Consumer bytes-fetched metric uses decompressed

[jira] [Updated] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4794: Fix Version/s: (was: 2.1.0) 2.2.0 > Add access to OffsetStorageReader from

[jira] [Updated] (KAFKA-4931) stop script fails due 4096 ps output limit

[ https://issues.apache.org/jira/browse/KAFKA-4931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4931: Fix Version/s: (was: 2.1.0) 2.2.0 > stop script fails due 4096 ps output limit >

[jira] [Commented] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636527#comment-16636527 ] Dong Lin commented on KAFKA-4794: - Since there has been no activity on this for several months, moving

[jira] [Updated] (KAFKA-4126) No relevant log when the topic is non-existent

[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4126: Fix Version/s: (was: 2.1.0) 2.2.0 > No relevant log when the topic is non-existent

[jira] [Updated] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace

[ https://issues.apache.org/jira/browse/KAFKA-5359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5359: Fix Version/s: (was: 2.1.0) 2.2.0 > Exceptions from RequestFuture lack parts of the

[jira] [Updated] (KAFKA-6448) Mx4jLoader#props.getBoolean("kafka_mx4jenable", false) conflict with the annotation

[ https://issues.apache.org/jira/browse/KAFKA-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6448: Fix Version/s: (was: 2.1.0) 2.2.0 > Mx4jLoader#props.getBoolean("kafka_mx4jenable",

[jira] [Updated] (KAFKA-5517) Support linking to particular configuration parameters

[ https://issues.apache.org/jira/browse/KAFKA-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5517: Fix Version/s: (was: 2.1.0) 2.2.0 > Support linking to particular configuration

[jira] [Updated] (KAFKA-5479) Docs for authorization omit authorizer.class.name

[ https://issues.apache.org/jira/browse/KAFKA-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5479: Fix Version/s: (was: 2.1.0) 2.2.0 > Docs for authorization omit

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636524#comment-16636524 ] Dong Lin commented on KAFKA-4893: - Since there has been no activity on this for several weeks, moving

[jira] [Updated] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4893: Fix Version/s: (was: 2.1.0) 2.2.0 > async topic deletion conflicts with max topic

[jira] [Updated] (KAFKA-6951) Implement offset expiration semantics for unsubscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6951: Fix Version/s: (was: 2.1.0) 2.2.0 > Implement offset expiration semantics for

[jira] [Commented] (KAFKA-6951) Implement offset expiration semantics for unsubscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636523#comment-16636523 ] Dong Lin commented on KAFKA-6951: - Move to 2.2.0 since PR is not ready. > Implement offset expiration

[jira] [Updated] (KAFKA-3143) inconsistent state in ZK when all replicas are dead

[ https://issues.apache.org/jira/browse/KAFKA-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3143: Fix Version/s: (was: 2.1.0) 2.2.0 > inconsistent state in ZK when all replicas are

[jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4133: Fix Version/s: (was: 2.1.0) 2.2.0 > Provide a configuration to control consumer max

[jira] [Updated] (KAFKA-5795) Make the idempotent producer the default producer setting

[ https://issues.apache.org/jira/browse/KAFKA-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5795: Fix Version/s: (was: 2.1.0) 2.2.0 > Make the idempotent producer the default

[jira] [Updated] (KAFKA-5284) Add tools and metrics to diagnose problems with the idempotent producer and transactions

[ https://issues.apache.org/jira/browse/KAFKA-5284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5284: Fix Version/s: (was: 2.1.0) 2.2.0 > Add tools and metrics to diagnose problems with

[jira] [Updated] (KAFKA-6509) Add additional tests for validating store restoration completes before Topology is intitalized

[ https://issues.apache.org/jira/browse/KAFKA-6509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6509: Fix Version/s: (was: 2.1.0) 2.2.0 > Add additional tests for validating store

[jira] [Updated] (KAFKA-6463) Review logging level for user errors in AdminManager

[ https://issues.apache.org/jira/browse/KAFKA-6463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6463: Fix Version/s: (was: 2.1.0) 2.2.0 > Review logging level for user errors in

[jira] [Commented] (KAFKA-5284) Add tools and metrics to diagnose problems with the idempotent producer and transactions

[ https://issues.apache.org/jira/browse/KAFKA-5284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636520#comment-16636520 ] Dong Lin commented on KAFKA-5284: - Move to 2.2.0 since PR is not ready.   > Add tools and metrics to

[jira] [Commented] (KAFKA-6463) Review logging level for user errors in AdminManager

[ https://issues.apache.org/jira/browse/KAFKA-6463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636519#comment-16636519 ] Dong Lin commented on KAFKA-6463: - Move to 2.2.0 since PR is not ready. > Review logging level for user

[jira] [Updated] (KAFKA-5606) Review consumer's RequestFuture usage pattern

[ https://issues.apache.org/jira/browse/KAFKA-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5606: Fix Version/s: (was: 2.1.0) 2.2.0 > Review consumer's RequestFuture usage pattern >

[jira] [Updated] (KAFKA-5780) Long shutdown time when updated to 0.11.0

[ https://issues.apache.org/jira/browse/KAFKA-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5780: Fix Version/s: (was: 2.1.0) 2.2.0 > Long shutdown time when updated to 0.11.0 >

[jira] [Updated] (KAFKA-5482) A CONCURRENT_TRANASCTIONS error for the first AddPartitionsToTxn request slows down transactions significantly

[ https://issues.apache.org/jira/browse/KAFKA-5482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5482: Fix Version/s: (was: 2.1.0) 2.2.0 > A CONCURRENT_TRANASCTIONS error for the first

[jira] [Commented] (KAFKA-5356) Producer with transactionalId should be able to send outside of a transaction

[ https://issues.apache.org/jira/browse/KAFKA-5356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636515#comment-16636515 ] Dong Lin commented on KAFKA-5356: - Move to 2.2.0 since PR is not ready. > Producer with transactionalId

[jira] [Updated] (KAFKA-5356) Producer with transactionalId should be able to send outside of a transaction

[ https://issues.apache.org/jira/browse/KAFKA-5356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5356: Fix Version/s: (was: 2.1.0) 2.2.0 > Producer with transactionalId should be able to

[jira] [Updated] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5870: Fix Version/s: (was: 2.1.0) 2.2.0 > Idempotent producer: a producerId reset causes

[jira] [Commented] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635781#comment-16635781 ] Dong Lin commented on KAFKA-5870: - Moving this to 2.2.0 since PR is not ready yet. > Idempotent

[jira] [Updated] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time

[ https://issues.apache.org/jira/browse/KAFKA-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5116: Fix Version/s: (was: 2.1.0) 2.2.0 > Controller updates to ISR holds the controller

[jira] [Commented] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time

[ https://issues.apache.org/jira/browse/KAFKA-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635780#comment-16635780 ] Dong Lin commented on KAFKA-5116: - Moving this to 2.2.0 since PR is not ready yet. > Controller updates

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5453: Fix Version/s: (was: 2.1.0) 2.2.0 > Controller may miss requests sent to the broker

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5453: Fix Version/s: (was: 2.2.0) 2.1.0 > Controller may miss requests sent to the broker

[jira] [Updated] (KAFKA-5601) Refactor ReassignPartitionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5601: Fix Version/s: (was: 2.1.0) 2.2.0 > Refactor ReassignPartitionsCommand to use

[jira] [Commented] (KAFKA-5022) Improve CRC tests so that we verify which fields are included in the CRC

[ https://issues.apache.org/jira/browse/KAFKA-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635635#comment-16635635 ] Dong Lin commented on KAFKA-5022: - Moving this to 2.2.0 since PR is not ready yet. > Improve CRC tests

[jira] [Updated] (KAFKA-5022) Improve CRC tests so that we verify which fields are included in the CRC

[ https://issues.apache.org/jira/browse/KAFKA-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5022: Fix Version/s: (was: 2.1.0) 2.2.0 > Improve CRC tests so that we verify which

[jira] [Commented] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down

[ https://issues.apache.org/jira/browse/KAFKA-5736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635637#comment-16635637 ] Dong Lin commented on KAFKA-5736: - Moving this to 2.2.0 since PR is not ready yet. > Improve error

[jira] [Commented] (KAFKA-5601) Refactor ReassignPartitionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635634#comment-16635634 ] Dong Lin commented on KAFKA-5601: - Moving this to 2.2.0 since PR is not ready yet. > Refactor

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6007: Fix Version/s: (was: 2.1.0) 2.2.0 > Connect can't validate against transforms in

[jira] [Commented] (KAFKA-6007) Connect can't validate against transforms in plugins.path

[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635630#comment-16635630 ] Dong Lin commented on KAFKA-6007: - Moving this to 2.2.0 since PR is not ready yet. > Connect can't

[jira] [Commented] (KAFKA-5478) TransactionsTest.testFencingOnAddPartitions Timeout

[ https://issues.apache.org/jira/browse/KAFKA-5478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635632#comment-16635632 ] Dong Lin commented on KAFKA-5478: - Moving this to 2.2.0 since PR is not ready yet. >

[jira] [Updated] (KAFKA-5478) TransactionsTest.testFencingOnAddPartitions Timeout

[ https://issues.apache.org/jira/browse/KAFKA-5478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5478: Fix Version/s: (was: 2.1.0) 2.2.0 > TransactionsTest.testFencingOnAddPartitions

[jira] [Updated] (KAFKA-5030) Suggested clean-ups from message format V2 review

[ https://issues.apache.org/jira/browse/KAFKA-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5030: Fix Version/s: (was: 2.1.0) 2.2.0 > Suggested clean-ups from message format V2

[jira] [Commented] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635610#comment-16635610 ] Dong Lin commented on KAFKA-5453: - Moving this to 2.2.0 since PR is not ready yet. > Controller may miss

<    1   2   3   4   5   6   7   >