[jira] [Created] (KAFKA-7470) Thread safe accumulator across all instances

sam created KAFKA-7470: -- Summary: Thread safe accumulator across all instances Key: KAFKA-7470 URL: https://issues.apache.org/jira/browse/KAFKA-7470 Project: Kafka Issue Type: New Feature Comp

[jira] [Updated] (KAFKA-7470) Thread safe accumulator across all instances

[ https://issues.apache.org/jira/browse/KAFKA-7470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sam updated KAFKA-7470: --- Description: Spark has a useful API for accumulating data in a thread safe way  [https://spark.apache.org/docs/2.3.0/

[jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635191#comment-16635191 ] ASF GitHub Bot commented on KAFKA-7075: --- lmontrieux opened a new pull request #5725

[jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635193#comment-16635193 ] Lionel Montrieux commented on KAFKA-7075: - It seems that there hasn't been any ac

[jira] [Commented] (KAFKA-7352) KIP-368: Allow SASL Connections to Periodically Re-Authenticate

[ https://issues.apache.org/jira/browse/KAFKA-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635353#comment-16635353 ] Dong Lin commented on KAFKA-7352: - PR can be found at [https://github.com/apache/kafka/pu

[jira] [Updated] (KAFKA-7352) KIP-368: Allow SASL Connections to Periodically Re-Authenticate

[ https://issues.apache.org/jira/browse/KAFKA-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7352: Fix Version/s: 2.1.0 > KIP-368: Allow SASL Connections to Periodically Re-Authenticate > --

[jira] [Resolved] (KAFKA-7406) Naming Join and Grouping Repartition Topics

[ https://issues.apache.org/jira/browse/KAFKA-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7406. - Resolution: Fixed > Naming Join and Grouping Repartition Topics > ---

[jira] [Commented] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

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

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Fix Version/s: (was: 2.1.0) 2.2.0 > Fail to shutdown ReplicaManager during broker cl

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Fix Version/s: (was: 2.2.0) 2.1.0 > Fail to shutdown ReplicaManager during broker cl

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Priority: Blocker (was: Critical) > Fail to shutdown ReplicaManager during broker cleaned shutdown > -

[jira] [Issue Comment Deleted] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Comment: was deleted (was: Moving this to 2.2.0 since the PR is not ready.) > Fail to shutdown ReplicaMana

[jira] [Updated] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

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

[jira] [Updated] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7304: Fix Version/s: 2.1.1 > memory leakage in org.apache.kafka.common.network.Selector > ---

[jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

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

[jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

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

[jira] [Commented] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635532#comment-16635532 ] Dong Lin commented on KAFKA-5054: - [~damianguy] It seems that the PR has passed review bu

[jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3955: Fix Version/s: (was: 2.1.0) 2.2.0 > Kafka log recovery doesn't truncate logs on non-

[jira] [Created] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

Alex Dunayevsky created KAFKA-7471: -- Summary: Multiple Consumer Group Management (Describe, Reset, Delete) Key: KAFKA-7471 URL: https://issues.apache.org/jira/browse/KAFKA-7471 Project: Kafka

[jira] [Updated] (KAFKA-4701) Allow kafka brokers to dynamically reload truststore without restarting.

[ https://issues.apache.org/jira/browse/KAFKA-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4701: Fix Version/s: (was: 2.1.0) 2.2.0 > Allow kafka brokers to dynamically reload trusts

[jira] [Updated] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

[ https://issues.apache.org/jira/browse/KAFKA-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3438: Fix Version/s: (was: 2.1.0) 2.2.0 > Rack Aware Replica Reassignment should warn of o

[jira] [Updated] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7037: Fix Version/s: (was: 2.1.0) > delete topic command replaces '+' from the topic name which leads incorre

[jira] [Updated] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-7471: --- Description: Functionality needed: * Describe/Delete/Reset offsets on multiple consumer grou

[jira] [Updated] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-7471: --- Description: Functionality needed: * Describe/Delete/Reset offsets on multiple consumer grou

[jira] [Updated] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings

[ https://issues.apache.org/jira/browse/KAFKA-6342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6342: Fix Version/s: (was: 2.1.0) 2.2.0 > Move workaround for JSON parsing of non-escaped

[jira] [Updated] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7037: Fix Version/s: 2.2.0 > delete topic command replaces '+' from the topic name which leads incorrect > topic

[jira] [Updated] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-7471: --- Description: Functionality needed: * Describe/Delete/Reset offsets on multiple consumer grou

[jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4808: Fix Version/s: (was: 2.1.0) 2.2.0 > send of null key to a compacted topic should thr

[jira] [Updated] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-7471: --- Description: Functionality needed: * Describe/Delete/Reset offsets on multiple consumer grou

[jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters

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

[jira] [Updated] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-7471: --- Description: Functionality needed: * Describe/Delete/Reset offsets on multiple consumer grou

[jira] [Created] (KAFKA-7472) Implement KIP-145 transformations

Randall Hauch created KAFKA-7472: Summary: Implement KIP-145 transformations Key: KAFKA-7472 URL: https://issues.apache.org/jira/browse/KAFKA-7472 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635545#comment-16635545 ] Dong Lin commented on KAFKA-3297: - Since there has been no activity on the PR for several

[jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3297: Fix Version/s: (was: 2.1.0) 2.2.0 > More optimally balanced partition assignment str

[jira] [Updated] (KAFKA-5952) Refactor Consumer Fetcher metrics

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

[jira] [Updated] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

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

[jira] [Commented] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635547#comment-16635547 ] Dong Lin commented on KAFKA-5951: - Since there has been no activity on the PR for several

[jira] [Commented] (KAFKA-5952) Refactor Consumer Fetcher metrics

[ https://issues.apache.org/jira/browse/KAFKA-5952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635546#comment-16635546 ] Dong Lin commented on KAFKA-5952: - Since there has been no activity on the PR for several

[jira] [Commented] (KAFKA-5403) Transactions system test should dedup consumed messages by offset

[ https://issues.apache.org/jira/browse/KAFKA-5403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635548#comment-16635548 ] Dong Lin commented on KAFKA-5403: - Closing this JIRA based on the comment in the PR. > T

[jira] [Commented] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635549#comment-16635549 ] Dong Lin commented on KAFKA-4862: - Since there has been no activity on the PR for several

[jira] [Updated] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4862: Fix Version/s: (was: 2.1.0) 2.2.0 > Kafka client connect to a shutdown node will blo

[jira] [Updated] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling

[ https://issues.apache.org/jira/browse/KAFKA-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4665: Fix Version/s: (was: 2.1.0) 2.2.0 > Inconsistent handling of non-existing topics in

[jira] [Commented] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling

[ https://issues.apache.org/jira/browse/KAFKA-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635550#comment-16635550 ] Dong Lin commented on KAFKA-4665: - Since there has been no activity on the PR for several

[jira] [Commented] (KAFKA-4307) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635551#comment-16635551 ] Dong Lin commented on KAFKA-4307: - Since there has been no activity on the PR for several

[jira] [Updated] (KAFKA-4307) Inconsistent parameters between console producer and consumer

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

[jira] [Resolved] (KAFKA-6415) KafkaLog4jAppender deadlocks when logging from producer network thread

[ https://issues.apache.org/jira/browse/KAFKA-6415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6415. - Resolution: Fixed > KafkaLog4jAppender deadlocks when logging from producer network thread >

[jira] [Commented] (KAFKA-6780) log cleaner shouldn't clean messages beyond high watermark

[ https://issues.apache.org/jira/browse/KAFKA-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635552#comment-16635552 ] Dong Lin commented on KAFKA-6780: - Moving this out to 2.2.0 since there is no PR yet. >

[jira] [Updated] (KAFKA-6780) log cleaner shouldn't clean messages beyond high watermark

[ https://issues.apache.org/jira/browse/KAFKA-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6780: Fix Version/s: (was: 2.1.0) 2.2.0 > log cleaner shouldn't clean messages beyond high

[jira] [Updated] (KAFKA-6836) Upgrade metrics library

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

[jira] [Commented] (KAFKA-6836) Upgrade metrics library

[ https://issues.apache.org/jira/browse/KAFKA-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635553#comment-16635553 ] Dong Lin commented on KAFKA-6836: - Moving this to 2.2.0 sine there is no PR yet. > Upgra

[jira] [Commented] (KAFKA-6784) FindCoordinatorResponse cannot be cast to FetchResponse

[ https://issues.apache.org/jira/browse/KAFKA-6784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1663#comment-1663 ] Dong Lin commented on KAFKA-6784: - Moving this to 2.2.0 since there is no progress in the

[jira] [Commented] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit

[ https://issues.apache.org/jira/browse/KAFKA-5955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635557#comment-16635557 ] Dong Lin commented on KAFKA-5955: - Moving this to 2.2.0 since there is no progress in the

[jira] [Updated] (KAFKA-6784) FindCoordinatorResponse cannot be cast to FetchResponse

[ https://issues.apache.org/jira/browse/KAFKA-6784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6784: Fix Version/s: (was: 2.1.0) 2.2.0 > FindCoordinatorResponse cannot be cast to FetchR

[jira] [Updated] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit

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

[jira] [Commented] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635559#comment-16635559 ] Dong Lin commented on KAFKA-6438: - Closing this PR since it may be fixed in KAFKA-6630. W

[jira] [Resolved] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6438. - Resolution: Won't Fix > NSEE while concurrently creating and deleting a topic > -

[jira] [Commented] (KAFKA-7200) Preserve serdes used

[ https://issues.apache.org/jira/browse/KAFKA-7200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635562#comment-16635562 ] Dong Lin commented on KAFKA-7200: - Moving this to 2.2.0 since there is no PR yet. > Pres

[jira] [Updated] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6438: Fix Version/s: (was: 2.1.0) > NSEE while concurrently creating and deleting a topic > -

[jira] [Commented] (KAFKA-4928) Add integration test for DumpLogSegments

[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635564#comment-16635564 ] Dong Lin commented on KAFKA-4928: - Moving this to 2.2.0 since there is no progress in the

[jira] [Commented] (KAFKA-7201) Optimize repartition operations

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635563#comment-16635563 ] Dong Lin commented on KAFKA-7201: - Moving this to 2.2.0 since there is no progress in the

[jira] [Updated] (KAFKA-7200) Preserve serdes used

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

[jira] [Updated] (KAFKA-7201) Optimize repartition operations

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

[jira] [Commented] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635568#comment-16635568 ] Dong Lin commented on KAFKA-4668: - Moving this to 2.2.0 since there is no progress in the

[jira] [Updated] (KAFKA-4928) Add integration test for DumpLogSegments

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

[jira] [Updated] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4668: Fix Version/s: (was: 2.1.0) 2.2.0 > Mirrormaker should default to auto.offset.reset=

[jira] [Updated] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny

[ https://issues.apache.org/jira/browse/KAFKA-5883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5883: Fix Version/s: (was: 2.1.0) 2.2.0 > Run tests on Java 9 with –illegal-access=deny >

[jira] [Commented] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny

[ https://issues.apache.org/jira/browse/KAFKA-5883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635571#comment-16635571 ] Dong Lin commented on KAFKA-5883: - Moving this to 2.2.0 since there is no progress in the

[jira] [Updated] (KAFKA-4487) Tests should be run in Jenkins with INFO or DEBUG level

[ https://issues.apache.org/jira/browse/KAFKA-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4487: Fix Version/s: (was: 2.1.0) 2.2.0 > Tests should be run in Jenkins with INFO or DEBU

[jira] [Updated] (KAFKA-5480) Partition Leader may not be elected although there is one live replica in ISR

[ https://issues.apache.org/jira/browse/KAFKA-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5480: Fix Version/s: (was: 2.1.0) 2.2.0 > Partition Leader may not be elected although the

[jira] [Commented] (KAFKA-4487) Tests should be run in Jenkins with INFO or DEBUG level

[ https://issues.apache.org/jira/browse/KAFKA-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635573#comment-16635573 ] Dong Lin commented on KAFKA-4487: - Moving this to 2.2.0 since there is no progress in the

[jira] [Commented] (KAFKA-5480) Partition Leader may not be elected although there is one live replica in ISR

[ https://issues.apache.org/jira/browse/KAFKA-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635572#comment-16635572 ] Dong Lin commented on KAFKA-5480: - Moving this to 2.2.0 since there is no progress in the

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

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

[jira] [Commented] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635576#comment-16635576 ] Dong Lin commented on KAFKA-5092: - Moving this to 2.2.0 since KIP-141 is not accepted yet

[jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint

[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635578#comment-16635578 ] Dong Lin commented on KAFKA-6761: - Closing this Jira since all 6 PRs have been merged/clo

[jira] [Resolved] (KAFKA-6761) Reduce Kafka Streams Footprint

[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6761. - Resolution: Fixed > Reduce Kafka Streams Footprint > -- > > K

[jira] [Updated] (KAFKA-6874) Add Configuration Allowing for Optional Topology Optimization

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

[jira] [Commented] (KAFKA-6874) Add Configuration Allowing for Optional Topology Optimization

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

[jira] [Updated] (KAFKA-5023) Remove cyclic dependency between record and protocol packages

[ https://issues.apache.org/jira/browse/KAFKA-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5023: Fix Version/s: (was: 2.1.0) 2.2.0 > Remove cyclic dependency between record and prot

[jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

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

[jira] [Updated] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2200: Fix Version/s: (was: 2.1.0) 2.2.0 > kafkaProducer.send() should not call callback.on

[jira] [Commented] (KAFKA-5023) Remove cyclic dependency between record and protocol packages

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

[jira] [Updated] (KAFKA-5255) Auto generate request/response classes

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

[jira] [Commented] (KAFKA-5270) TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction

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

[jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5503: Fix Version/s: (was: 2.1.0) 2.2.0 > Idempotent producer ignores shutdown while fetch

[jira] [Commented] (KAFKA-5255) Auto generate request/response classes

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

[jira] [Updated] (KAFKA-5270) TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction

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

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

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

[jira] [Commented] (KAFKA-5661) Develop and understanding of how to tune transactions for optimal performance

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

[jira] [Updated] (KAFKA-5661) Develop and understanding of how to tune transactions for optimal performance

[ https://issues.apache.org/jira/browse/KAFKA-5661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5661: Fix Version/s: (was: 2.1.0) 2.2.0 > Develop and understanding of how to tune transac

[jira] [Resolved] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5018. - Resolution: Won't Do > LogCleaner tests to verify behaviour of message format v2 > --

[jira] [Updated] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5018: Fix Version/s: (was: 2.1.0) 2.2.0 > LogCleaner tests to verify behaviour of message

[jira] [Reopened] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reopened KAFKA-5018: - > LogCleaner tests to verify behaviour of message format v2 > ---

[jira] [Commented] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

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

[jira] [Commented] (KAFKA-6124) Revisit default config for internal client with regard to resilience

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

[jira] [Updated] (KAFKA-5383) Additional Test Cases for ReplicaManager

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

[jira] [Commented] (KAFKA-5383) Additional Test Cases for ReplicaManager

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

[jira] [Commented] (KAFKA-6276) AdminClient may leave some futures hanging after shutdown

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

[jira] [Updated] (KAFKA-6276) AdminClient may leave some futures hanging after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6276: Fix Version/s: (was: 2.1.0) 2.2.0 > AdminClient may leave some futures hanging after

[jira] [Updated] (KAFKA-5729) Consumer should verify offset commits are from assigned partitions

[ https://issues.apache.org/jira/browse/KAFKA-5729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5729: Fix Version/s: (was: 2.1.0) 2.2.0 > Consumer should verify offset commits are from a

[jira] [Updated] (KAFKA-5945) Improve handling of authentication failures when credentials are removed

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

  1   2   >