[jira] [Commented] (KAFKA-5204) Connect needs to validate Connector type during instantiation

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

[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

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

[jira] [Updated] (KAFKA-3135) Unexpected delay before fetch response transmission

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

[jira] [Commented] (KAFKA-5041) Kafka TestKit library

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

[jira] [Commented] (KAFKA-5026) DebuggingConsumerId and DebuggingMessageFormatter and message format v2

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

[jira] [Updated] (KAFKA-5026) DebuggingConsumerId and DebuggingMessageFormatter and message format v2

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

[jira] [Commented] (KAFKA-5025) FetchRequestTest should use batches with more than one message

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

[jira] [Commented] (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:comment-tabpanel=16635601#comment-16635601 ] Dong Lin commented on KAFKA-5945: - Moving this to 2.2.0 since PR is not ready yet. > Improve handling of

[jira] [Updated] (KAFKA-5451) Kafka Connect should scan classpath asynchronously

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

[jira] [Commented] (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:comment-tabpanel=16635599#comment-16635599 ] Dong Lin commented on KAFKA-5729: - Moving this to 2.2.0 since PR is not ready yet. > Consumer should

[jira] [Commented] (KAFKA-5451) Kafka Connect should scan classpath asynchronously

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

[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

[jira] [Updated] (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:all-tabpanel ] Dong Lin updated KAFKA-6124: Fix Version/s: (was: 2.1.0) 2.2.0 > Revisit default config for internal client with

[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

[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=16635595#comment-16635595 ] Dong Lin commented on KAFKA-5383: - Moving this to 2.2.0 since PR is not ready yet. > Additional Test

[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=16635596#comment-16635596 ] Dong Lin commented on KAFKA-6276: - Moving this to 2.2.0 since PR is not ready yet. > AdminClient may

[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

[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=16635597#comment-16635597 ] Dong Lin commented on KAFKA-6124: - Moving this to 2.2.0 since PR is not ready yet. > Revisit default

[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-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=16635594#comment-16635594 ] Dong Lin commented on KAFKA-5018: - Moving this to 2.2.0 since PR is not ready yet. > LogCleaner tests to

[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] [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-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

[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=16635587#comment-16635587 ] Dong Lin commented on KAFKA-5255: - Moving this to 2.2.0 since PR is not ready yet. > Auto generate

[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

[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=16635591#comment-16635591 ] Dong Lin commented on KAFKA-5503: - Moving this to 2.2.0 since PR is not ready yet. > Idempotent producer

[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=16635590#comment-16635590 ] Dong Lin commented on KAFKA-5270: - Moving this to 2.2.0 since PR is not ready yet. > TransactionManager

[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

[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] [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

[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=16635585#comment-16635585 ] Dong Lin commented on KAFKA-5023: - Moving this to 2.2.0 since PR is not ready yet. > Remove cyclic

[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

[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=16635581#comment-16635581 ] Dong Lin commented on KAFKA-6874: - Moving this to 2.2.0 since PR is not ready yet. > Add Configuration

[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

[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 > -- > >

[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=16635578#comment-16635578 ] Dong Lin commented on KAFKA-6761: - Closing this Jira since all 6 PRs have been merged/closed > Reduce

[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=16635576#comment-16635576 ] Dong Lin commented on KAFKA-5092: - Moving this to 2.2.0 since KIP-141 is not accepted yet. > KIP 141 -

[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-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=16635572#comment-16635572 ] Dong Lin commented on KAFKA-5480: - Moving this to 2.2.0 since there is no progress in the past few

[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=16635573#comment-16635573 ] Dong Lin commented on KAFKA-4487: - Moving this to 2.2.0 since there is no progress in the past few

[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

[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

[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=16635571#comment-16635571 ] Dong Lin commented on KAFKA-5883: - Moving this to 2.2.0 since there is no progress in the past few

[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] [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

[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] [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=16635568#comment-16635568 ] Dong Lin commented on KAFKA-4668: - Moving this to 2.2.0 since there is no progress in the past few

[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-7201) Optimize repartition operations

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

[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-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] [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=16635562#comment-16635562 ] Dong Lin commented on KAFKA-7200: - Moving this to 2.2.0 since there is no PR yet. > Preserve serdes used

[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=16635559#comment-16635559 ] Dong Lin commented on KAFKA-6438: - Closing this PR since it may be fixed in KAFKA-6630. We can re-open it

[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: >

[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

[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=16635557#comment-16635557 ] Dong Lin commented on KAFKA-5955: - Moving this to 2.2.0 since there is no progress in the past few

[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=1663#comment-1663 ] Dong Lin commented on KAFKA-6784: - Moving this to 2.2.0 since there is no progress in the past few

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

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

[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] [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

[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=16635552#comment-16635552 ] Dong Lin commented on KAFKA-6780: - Moving this out to 2.2.0 since there is no PR yet. > log cleaner

[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] [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

[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=16635551#comment-16635551 ] Dong Lin commented on KAFKA-4307: - Since there has been no activity on the PR for several months, moving

[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=16635550#comment-16635550 ] Dong Lin commented on KAFKA-4665: - Since there has been no activity on the PR for several months, moving

[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

[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=16635549#comment-16635549 ] Dong Lin commented on KAFKA-4862: - Since there has been no activity on the PR for several months, moving

[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=16635548#comment-16635548 ] Dong Lin commented on KAFKA-5403: - Closing this JIRA based on the comment in the PR. > Transactions

[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=16635546#comment-16635546 ] Dong Lin commented on KAFKA-5952: - Since there has been no activity on the PR for several months, moving

[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=16635547#comment-16635547 ] Dong Lin commented on KAFKA-5951: - Since there has been no activity on the PR for several months, moving

[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] [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-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

[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-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

[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 >

[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: (was: 2.1.0) > delete topic command replaces '+' from the topic name which leads

[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

[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

[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

[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=16635532#comment-16635532 ] Dong Lin commented on KAFKA-5054: - [~damianguy] It seems that the PR has passed review but it is deleted

[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 >

[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 >

[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-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

[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

[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

[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

[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=16635512#comment-16635512 ] Dong Lin commented on KAFKA-7464: - Moving this to 2.2.0 since the PR is not ready. > Fail to shutdown

[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] [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] [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=16635353#comment-16635353 ] Dong Lin commented on KAFKA-7352: - PR can be found at [https://github.com/apache/kafka/pull/5582] >

[jira] [Reopened] (KAFKA-4218) Enable access to key in ValueTransformer

[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reopened KAFKA-4218: - Thanks for working on this [~jeyhunkarimov]! For KIP-149, currently there are 4 PRs: -

[jira] [Updated] (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 updated KAFKA-7441: Priority: Blocker (was: Major) > Allow LogCleanerManager.resumeCleaning() to be used concurrently >

[jira] [Updated] (KAFKA-7313) StopReplicaRequest should attempt to remove future replica for the partition only if future replica exists

[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7313: Summary: StopReplicaRequest should attempt to remove future replica for the partition only if future

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

[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628201#comment-16628201 ] Dong Lin commented on KAFKA-7441: - PR can be found at [https://github.com/apache/kafka/pull/5694] >

<    1   2   3   4   5   6   7   >