[jira] [Commented] (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:comment-tabpanel=16637717#comment-16637717 ] Narayan Periwal commented on KAFKA-7026: [~steven.aerts] [~vahid] As I mentioned in KAFKA-6681,

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

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

[jira] [Closed] (KAFKA-7393) Consider making suppression node names independent of topologically numbered names.

[ https://issues.apache.org/jira/browse/KAFKA-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-7393. --- > Consider making suppression node names independent of topologically numbered > names. >

[jira] [Resolved] (KAFKA-7393) Consider making suppression node names independent of topologically numbered names.

[ https://issues.apache.org/jira/browse/KAFKA-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7393. - Resolution: Won't Fix We realized that Suppressed needs to support a name parameter in keeping

[jira] [Created] (KAFKA-7477) Improve Streams close timeout semantics

John Roesler created KAFKA-7477: --- Summary: Improve Streams close timeout semantics Key: KAFKA-7477 URL: https://issues.apache.org/jira/browse/KAFKA-7477 Project: Kafka Issue Type: Improvement

[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=16637351#comment-16637351 ] Matthias J. Sax commented on KAFKA-7149: [~guozhang] Do we still aim to get this into 2.1 ? >

[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 ] Matthias J. Sax updated KAFKA-6509: --- Fix Version/s: (was: 2.2.0) > Add additional tests for validating store restoration

[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 ] Matthias J. Sax updated KAFKA-3596: --- Fix Version/s: (was: 2.2.0) > Kafka Streams: Window expiration needs to consider more

[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 ] Matthias J. Sax updated KAFKA-7198: --- Fix Version/s: (was: 2.2.0) > Enhance KafkaStreams start method javadoc >

[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 ] Matthias J. Sax updated KAFKA-5876: --- Fix Version/s: (was: 2.2.0) > IQ should throw different exceptions for different errors

[jira] [Commented] (KAFKA-7476) SchemaProjector is not properly handling Date-based logical types

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

[jira] [Commented] (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:comment-tabpanel=16637302#comment-16637302 ] Steven Aerts commented on KAFKA-7026: - [~nperiwal] no, I do not think so, as that one is "stateless",

[jira] [Commented] (KAFKA-6123) Give client MetricsReporter auto-generated client.id

[ https://issues.apache.org/jira/browse/KAFKA-6123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16637198#comment-16637198 ] ASF GitHub Bot commented on KAFKA-6123: --- cmccabe closed pull request #5383: KAFKA-6123: Give client

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16637193#comment-16637193 ] ASF GitHub Bot commented on KAFKA-7223: --- guozhangwang closed pull request #5724: KAFKA-7223: Make

[jira] [Commented] (KAFKA-3097) Acls for PrincipalType User are case sensitive

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

[jira] [Commented] (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:comment-tabpanel=16636936#comment-16636936 ] ASF GitHub Bot commented on KAFKA-7462: --- rajinisivaram opened a new pull request #5733: KAFKA-7462:

[jira] [Commented] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636931#comment-16636931 ] Caio Boratto commented on KAFKA-7157: - Is there any workaround that we can use while the bug has not

[jira] [Commented] (KAFKA-6632) Very slow hashCode methods in Kafka Connect types

[ https://issues.apache.org/jira/browse/KAFKA-6632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636918#comment-16636918 ] ASF GitHub Bot commented on KAFKA-6632: --- maver1ck closed pull request #4700: KAFKA-6632: Very slow

[jira] [Resolved] (KAFKA-6632) Very slow hashCode methods in Kafka Connect types

[ https://issues.apache.org/jira/browse/KAFKA-6632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński resolved KAFKA-6632. --- Resolution: Fixed > Very slow hashCode methods in Kafka Connect types >

[jira] [Resolved] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński resolved KAFKA-6626. --- Resolution: Unresolved > Performance bottleneck in Kafka Connect sendRecords >

[jira] [Comment Edited] (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:comment-tabpanel=16636871#comment-16636871 ] Narayan Periwal edited comment on KAFKA-7026 at 10/3/18 12:05 PM: --

[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] [Comment Edited] (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:comment-tabpanel=16636871#comment-16636871 ] Narayan Periwal edited comment on KAFKA-7026 at 10/3/18 12:04 PM: --

[jira] [Commented] (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:comment-tabpanel=16636871#comment-16636871 ] Narayan Periwal commented on KAFKA-7026: [~steven.aerts], can the issue of "consumer of the

[jira] [Resolved] (KAFKA-3601) fail fast when newer client connecting to older server

[ https://issues.apache.org/jira/browse/KAFKA-3601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3601. -- Resolution: Fixed Closing in favour of newer releases.  Please reopen if you think otherwise > fail

[jira] [Commented] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

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

[jira] [Comment Edited] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

[ https://issues.apache.org/jira/browse/KAFKA-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636729#comment-16636729 ] Dmitrii edited comment on KAFKA-6971 at 10/3/18 10:23 AM: -- Hello! I would like

[jira] [Commented] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

[ https://issues.apache.org/jira/browse/KAFKA-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636729#comment-16636729 ] Dmitrii commented on KAFKA-6971: Hello! I would like to help with this task. [This pull

[jira] [Assigned] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

[ https://issues.apache.org/jira/browse/KAFKA-6724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky reassigned KAFKA-6724: -- Assignee: Alex Dunayevsky > ConsumerPerformance resets offsets on every startup >

[jira] [Resolved] (KAFKA-7429) Enable dynamic key/truststore update with same filename/password

[ https://issues.apache.org/jira/browse/KAFKA-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7429. -- Resolution: Fixed > Enable dynamic key/truststore update with same filename/password >

[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

  1   2   >