[jira] [Commented] (KAFKA-4041) kafka unable to reconnect to zookeeper behind an ELB

[ https://issues.apache.org/jira/browse/KAFKA-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636479#comment-16636479 ] Abhishek Agarwal commented on KAFKA-4041: - is there any chance that this can be backported to 1.x

[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=16636250#comment-16636250 ] Robert Yokota commented on KAFKA-7476: -- Here is a more detailed stack trace: {code:java} Caused by:

[jira] [Updated] (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:all-tabpanel ] Robert Yokota updated KAFKA-7476: - Description: SchemaProjector is not properly handling Date-based logical types.  An exception

[jira] [Updated] (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 ] Matthias J. Sax updated KAFKA-7406: --- Description: To help make Streams compatible with topology changes, we will need to give

[jira] [Commented] (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:comment-tabpanel=16636086#comment-16636086 ] ASF GitHub Bot commented on KAFKA-7475: --- radai-rosenblatt opened a new pull request #5729:

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

radai rosenblatt created KAFKA-7475: --- Summary: print the actual cluster bootstrap address on authentication failures Key: KAFKA-7475 URL: https://issues.apache.org/jira/browse/KAFKA-7475 Project:

[jira] [Commented] (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:comment-tabpanel=16636036#comment-16636036 ] ASF GitHub Bot commented on KAFKA-7429: --- cmccabe closed pull request #5699: KAFKA-7429: Enable

[jira] [Created] (KAFKA-7474) Conflicting statements in the replication docs

Joel Hamill created KAFKA-7474: -- Summary: Conflicting statements in the replication docs Key: KAFKA-7474 URL: https://issues.apache.org/jira/browse/KAFKA-7474 Project: Kafka Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/KAFKA-7200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635957#comment-16635957 ] Matthias J. Sax commented on KAFKA-7200: Passing Serdes downstream seems to be resolved via 

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

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635951#comment-16635951 ] Matthias J. Sax commented on KAFKA-7201: Seems to be contained (and thus resolved via 

[jira] [Comment Edited] (KAFKA-7201) Optimize repartition operations

[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635951#comment-16635951 ] Matthias J. Sax edited comment on KAFKA-7201 at 10/2/18 6:35 PM: - Seems

[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=16635948#comment-16635948 ] Matthias J. Sax commented on KAFKA-6874: Isn't this resolve in 2.0 already (via

[jira] [Commented] (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:comment-tabpanel=16635820#comment-16635820 ] John Roesler commented on KAFKA-7393: - Note that for suppression in particular, the behavior is

[jira] [Resolved] (KAFKA-7355) Topic Configuration Changes are not applied until reboot

[ https://issues.apache.org/jira/browse/KAFKA-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7355. -- Resolution: Duplicate Resolving as duplicate of KAFKA-7366. Raised a PR for KAFKA-7366.  > Topic

[jira] [Created] (KAFKA-7473) allow configuring kafka client configs to not warn for unknown config peoperties

radai rosenblatt created KAFKA-7473: --- Summary: allow configuring kafka client configs to not warn for unknown config peoperties Key: KAFKA-7473 URL: https://issues.apache.org/jira/browse/KAFKA-7473

[jira] [Commented] (KAFKA-7366) topic level segment.bytes and segment.ms not taking effect immediately

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635805#comment-16635805 ] Alex Dunayevsky commented on KAFKA-7471: Pull request: https://github.com/apache/kafka/pull/5726

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

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

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

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

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

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

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

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

[jira] [Updated] (KAFKA-7320) Provide ability to disable auto topic creation in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah updated KAFKA-7320: Fix Version/s: 2.1.0 > Provide ability to disable auto topic creation in KafkaConsumer >

[jira] [Commented] (KAFKA-7467) NoSuchElementException is raised because controlBatch is empty

[ https://issues.apache.org/jira/browse/KAFKA-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635692#comment-16635692 ] ASF GitHub Bot commented on KAFKA-7467: --- bob-barrett opened a new pull request #5727: KAFKA-7467:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [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 ] Ismael Juma updated KAFKA-3438: --- Fix Version/s: (was: 2.2.0) > Rack Aware Replica Reassignment should warn of overloaded brokers

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

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

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

  1   2   >