[jira] [Resolved] (KAFKA-7391) Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)

[ https://issues.apache.org/jira/browse/KAFKA-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7391. Resolution: Fixed Fix Version/s: 2.2.0 > Introduce close(Duration) to Producer and A

[jira] [Resolved] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7786. Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 > Fast update of lea

[jira] [Resolved] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6833. Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 > KafkaProducer thro

[jira] [Resolved] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

[ https://issues.apache.org/jira/browse/KAFKA-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7799. Resolution: Fixed > Fix flaky test RestServerTest.testCORSEnabled > ---

[jira] [Created] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

Jason Gustafson created KAFKA-7799: -- Summary: Fix flaky test RestServerTest.testCORSEnabled Key: KAFKA-7799 URL: https://issues.apache.org/jira/browse/KAFKA-7799 Project: Kafka Issue Type: T

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

[ https://issues.apache.org/jira/browse/KAFKA-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7051. Resolution: Fixed > Improve the efficiency of the ReplicaManager when there are many partit

[jira] [Resolved] (KAFKA-7253) The connector type responded by worker is always null when creating connector

[ https://issues.apache.org/jira/browse/KAFKA-7253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7253. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 2.

[jira] [Resolved] (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 ] Jason Gustafson resolved KAFKA-5503. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 > Idempotent produce

[jira] [Created] (KAFKA-7783) Improve testing of idempotent/transactional producer shutdown

Jason Gustafson created KAFKA-7783: -- Summary: Improve testing of idempotent/transactional producer shutdown Key: KAFKA-7783 URL: https://issues.apache.org/jira/browse/KAFKA-7783 Project: Kafka

[jira] [Resolved] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value

[ https://issues.apache.org/jira/browse/KAFKA-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3832. Resolution: Fixed Assignee: Renato Mefi (was: Prasanna Subburaj) Fix Versio

[jira] [Created] (KAFKA-7773) Use verifiable consumer in system tests to avoid reliance on console consumer idle timeout

Jason Gustafson created KAFKA-7773: -- Summary: Use verifiable consumer in system tests to avoid reliance on console consumer idle timeout Key: KAFKA-7773 URL: https://issues.apache.org/jira/browse/KAFKA-7773

[jira] [Created] (KAFKA-7771) Group/Transaction coordinators should update assignment based on current partition count

Jason Gustafson created KAFKA-7771: -- Summary: Group/Transaction coordinators should update assignment based on current partition count Key: KAFKA-7771 URL: https://issues.apache.org/jira/browse/KAFKA-7771

[jira] [Resolved] (KAFKA-7707) Some code is not necessary

[ https://issues.apache.org/jira/browse/KAFKA-7707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7707. Resolution: Not A Problem > Some code is not necessary > -- > >

[jira] [Created] (KAFKA-7764) Authentication exceptions during consumer metadata updates may not get propagated

Jason Gustafson created KAFKA-7764: -- Summary: Authentication exceptions during consumer metadata updates may not get propagated Key: KAFKA-7764 URL: https://issues.apache.org/jira/browse/KAFKA-7764 P

[jira] [Resolved] (KAFKA-7759) Disable WADL output on OPTIONS method in Connect REST

[ https://issues.apache.org/jira/browse/KAFKA-7759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7759. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 > Disable WADL outpu

[jira] [Created] (KAFKA-7747) Consumer should check for truncation after leader changes

Jason Gustafson created KAFKA-7747: -- Summary: Consumer should check for truncation after leader changes Key: KAFKA-7747 URL: https://issues.apache.org/jira/browse/KAFKA-7747 Project: Kafka I

[jira] [Resolved] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2334. Resolution: Fixed Fix Version/s: 2.2.0 > Prevent HW from going back during leader fa

[jira] [Resolved] (KAFKA-7712) Handle exceptions from immediately connected channels in Selector

[ https://issues.apache.org/jira/browse/KAFKA-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7712. Resolution: Fixed > Handle exceptions from immediately connected channels in Selector > ---

[jira] [Resolved] (KAFKA-7705) Update javadoc for the values of delivery.timeout.ms or linger.ms

[ https://issues.apache.org/jira/browse/KAFKA-7705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7705. Resolution: Fixed Fix Version/s: 2.1.1 > Update javadoc for the values of delivery.t

[jira] [Resolved] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7549. Resolution: Fixed > Old ProduceRequest with zstd compression does not return error to clien

[jira] [Resolved] (KAFKA-6388) Error while trying to roll a segment that already exists

[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6388. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 > Error while trying

[jira] [Resolved] (KAFKA-7687) Print batch level information in DumpLogSegments when deep iterating

[ https://issues.apache.org/jira/browse/KAFKA-7687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7687. Resolution: Fixed Fix Version/s: 2.2.0 > Print batch level information in DumpLogSeg

[jira] [Created] (KAFKA-7687) Print batch level information in DumpLogSegments when deep iterating

Jason Gustafson created KAFKA-7687: -- Summary: Print batch level information in DumpLogSegments when deep iterating Key: KAFKA-7687 URL: https://issues.apache.org/jira/browse/KAFKA-7687 Project: Kafka

[jira] [Resolved] (KAFKA-2931) Consumer rolling upgrade test case

[ https://issues.apache.org/jira/browse/KAFKA-2931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2931. Resolution: Fixed This was resolved by https://github.com/apache/kafka/pull/619. > Consume

[jira] [Resolved] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5110. Resolution: Won't Fix Closing this as "won't fix" for now. The consumer group command no lo

[jira] [Resolved] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7231. Resolution: Fixed Fix Version/s: 2.0.1 2.1.0 > NetworkClient.newC

[jira] [Resolved] (KAFKA-6352) Delay message down-conversion until response is ready to be sent

[ https://issues.apache.org/jira/browse/KAFKA-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6352. Resolution: Not A Problem This was addressed by [KIP-283|https://cwiki.apache.org/confluen

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

[ https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6774. Resolution: Fixed > Improve default groupId behavior in consumer >

[jira] [Created] (KAFKA-7610) Detect consumer failures in initial JoinGroup

Jason Gustafson created KAFKA-7610: -- Summary: Detect consumer failures in initial JoinGroup Key: KAFKA-7610 URL: https://issues.apache.org/jira/browse/KAFKA-7610 Project: Kafka Issue Type: I

[jira] [Created] (KAFKA-7605) Flaky Test `SaslMultiMechanismConsumerTest.testCoordinatorFailover`

Jason Gustafson created KAFKA-7605: -- Summary: Flaky Test `SaslMultiMechanismConsumerTest.testCoordinatorFailover` Key: KAFKA-7605 URL: https://issues.apache.org/jira/browse/KAFKA-7605 Project: Kafka

[jira] [Created] (KAFKA-7604) Flaky Test `ConsumerCoordinatorTest.testRebalanceAfterTopicUnavailableWithPatternSubscribe`

Jason Gustafson created KAFKA-7604: -- Summary: Flaky Test `ConsumerCoordinatorTest.testRebalanceAfterTopicUnavailableWithPatternSubscribe` Key: KAFKA-7604 URL: https://issues.apache.org/jira/browse/KAFKA-7604

[jira] [Created] (KAFKA-7601) Handle message format downgrades during upgrade of message format version

Jason Gustafson created KAFKA-7601: -- Summary: Handle message format downgrades during upgrade of message format version Key: KAFKA-7601 URL: https://issues.apache.org/jira/browse/KAFKA-7601 Project:

[jira] [Resolved] (KAFKA-7568) Return leader epoch in ListOffsets responses

[ https://issues.apache.org/jira/browse/KAFKA-7568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7568. Resolution: Fixed Fix Version/s: 2.2.0 > Return leader epoch in ListOffsets response

[jira] [Resolved] (KAFKA-7567) Clean up internal metadata usage for consistency and extensibility

[ https://issues.apache.org/jira/browse/KAFKA-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7567. Resolution: Fixed Fix Version/s: 2.2.0 > Clean up internal metadata usage for consis

[jira] [Created] (KAFKA-7571) Add system tests for downgrading Kafka

Jason Gustafson created KAFKA-7571: -- Summary: Add system tests for downgrading Kafka Key: KAFKA-7571 URL: https://issues.apache.org/jira/browse/KAFKA-7571 Project: Kafka Issue Type: Improvem

[jira] [Created] (KAFKA-7570) Make internal offsets/transaction schemas forward compatible

Jason Gustafson created KAFKA-7570: -- Summary: Make internal offsets/transaction schemas forward compatible Key: KAFKA-7570 URL: https://issues.apache.org/jira/browse/KAFKA-7570 Project: Kafka

[jira] [Created] (KAFKA-7568) Return leader epoch in ListOffsets responses

Jason Gustafson created KAFKA-7568: -- Summary: Return leader epoch in ListOffsets responses Key: KAFKA-7568 URL: https://issues.apache.org/jira/browse/KAFKA-7568 Project: Kafka Issue Type: Im

[jira] [Created] (KAFKA-7567) Clean up internal metadata usage for consistency and extensibility

Jason Gustafson created KAFKA-7567: -- Summary: Clean up internal metadata usage for consistency and extensibility Key: KAFKA-7567 URL: https://issues.apache.org/jira/browse/KAFKA-7567 Project: Kafka

[jira] [Resolved] (KAFKA-4514) Add Codec for ZStandard Compression

[ https://issues.apache.org/jira/browse/KAFKA-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4514. Resolution: Fixed Fix Version/s: 2.1.0 > Add Codec for ZStandard Compression > -

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

[ https://issues.apache.org/jira/browse/KAFKA-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6880. Resolution: Fixed Fix Version/s: (was: 2.2.0) 2.1.0 This was

[jira] [Resolved] (KAFKA-7395) Add fencing to replication protocol (KIP-320)

[ https://issues.apache.org/jira/browse/KAFKA-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7395. Resolution: Fixed Fix Version/s: 2.1.0 > Add fencing to replication protocol (KIP-32

[jira] [Resolved] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6914. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 1.

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

[ https://issues.apache.org/jira/browse/KAFKA-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7467. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 1.

[jira] [Created] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic`

Jason Gustafson created KAFKA-7486: -- Summary: Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic` Key: KAFKA-7486 URL: https://issues.apache.org/jira/browse/KAFKA-7486 Project: Kafka

[jira] [Created] (KAFKA-7485) Flaky test `DyanamicBrokerReconfigurationTest.testTrustStoreAlter`

Jason Gustafson created KAFKA-7485: -- Summary: Flaky test `DyanamicBrokerReconfigurationTest.testTrustStoreAlter` Key: KAFKA-7485 URL: https://issues.apache.org/jira/browse/KAFKA-7485 Project: Kafka

[jira] [Created] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

Jason Gustafson created KAFKA-7481: -- Summary: Consider options for safer upgrade of offset commit value schema Key: KAFKA-7481 URL: https://issues.apache.org/jira/browse/KAFKA-7481 Project: Kafka

[jira] [Resolved] (KAFKA-7415) OffsetsForLeaderEpoch may incorrectly respond with undefined epoch causing truncation to HW

[ https://issues.apache.org/jira/browse/KAFKA-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7415. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 > OffsetsForLeaderEp

[jira] [Resolved] (KAFKA-7409) Validate topic configs prior to topic creation

[ https://issues.apache.org/jira/browse/KAFKA-7409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7409. Resolution: Fixed Fix Version/s: 2.1.0 > Validate topic configs prior to topic creat

[jira] [Created] (KAFKA-7440) Use leader epoch in consumer fetch requests

Jason Gustafson created KAFKA-7440: -- Summary: Use leader epoch in consumer fetch requests Key: KAFKA-7440 URL: https://issues.apache.org/jira/browse/KAFKA-7440 Project: Kafka Issue Type: Imp

[jira] [Resolved] (KAFKA-7403) Offset commit failure after upgrading brokers past KIP-211/KAFKA-4682

[ https://issues.apache.org/jira/browse/KAFKA-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7403. Resolution: Fixed > Offset commit failure after upgrading brokers past KIP-211/KAFKA-4682 >

[jira] [Created] (KAFKA-7437) Store leader epoch in offset commit metadata

Jason Gustafson created KAFKA-7437: -- Summary: Store leader epoch in offset commit metadata Key: KAFKA-7437 URL: https://issues.apache.org/jira/browse/KAFKA-7437 Project: Kafka Issue Type: Im

[jira] [Resolved] (KAFKA-6923) Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

[ https://issues.apache.org/jira/browse/KAFKA-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6923. Resolution: Fixed > Consolidate ExtendedSerializer/Serializer and > ExtendedDeserializer/D

[jira] [Resolved] (KAFKA-7150) Error in processing fetched data for one partition may stop follower fetching other partitions

[ https://issues.apache.org/jira/browse/KAFKA-7150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7150. Resolution: Not A Problem This is no longer a problem since we have removed the logic to ra

[jira] [Resolved] (KAFKA-7414) Do not fail broker on out of range offsets in replica fetcher

[ https://issues.apache.org/jira/browse/KAFKA-7414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7414. Resolution: Fixed Fix Version/s: 2.1.0 > Do not fail broker on out of range offsets

[jira] [Resolved] (KAFKA-7280) ConcurrentModificationException in FetchSessionHandler in heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-7280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7280. Resolution: Fixed Fix Version/s: (was: 1.1.2) > ConcurrentModificationException

[jira] [Created] (KAFKA-7414) Do not fail broker on out of range offsets in replica fetcher

Jason Gustafson created KAFKA-7414: -- Summary: Do not fail broker on out of range offsets in replica fetcher Key: KAFKA-7414 URL: https://issues.apache.org/jira/browse/KAFKA-7414 Project: Kafka

[jira] [Created] (KAFKA-7409) Validate topic configs prior to topic creation

Jason Gustafson created KAFKA-7409: -- Summary: Validate topic configs prior to topic creation Key: KAFKA-7409 URL: https://issues.apache.org/jira/browse/KAFKA-7409 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7408) Truncate to LSO on unclean leader election

Jason Gustafson created KAFKA-7408: -- Summary: Truncate to LSO on unclean leader election Key: KAFKA-7408 URL: https://issues.apache.org/jira/browse/KAFKA-7408 Project: Kafka Issue Type: Impr

[jira] [Resolved] (KAFKA-7394) Allow OffsetsForLeaderEpoch requests with topic describe ACL (KIP-320)

[ https://issues.apache.org/jira/browse/KAFKA-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7394. Resolution: Fixed Fix Version/s: 2.1.0 > Allow OffsetsForLeaderEpoch requests with t

[jira] [Resolved] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7044. Resolution: Fixed Fix Version/s: 2.0.1 1.1.2 > kafka-consumer-gro

[jira] [Created] (KAFKA-7395) Add fencing to OffsetsForLeaderEpoch API (KIP-320)

Jason Gustafson created KAFKA-7395: -- Summary: Add fencing to OffsetsForLeaderEpoch API (KIP-320) Key: KAFKA-7395 URL: https://issues.apache.org/jira/browse/KAFKA-7395 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-7394) Allow OffsetsForLeaderEpoch requests with topic describe ACL (KIP-320)

Jason Gustafson created KAFKA-7394: -- Summary: Allow OffsetsForLeaderEpoch requests with topic describe ACL (KIP-320) Key: KAFKA-7394 URL: https://issues.apache.org/jira/browse/KAFKA-7394 Project: Kaf

[jira] [Resolved] (KAFKA-7286) Loading offsets and group metadata hangs with large group metadata records

[ https://issues.apache.org/jira/browse/KAFKA-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7286. Resolution: Fixed Fix Version/s: 2.1.0 > Loading offsets and group metadata hangs wi

[jira] [Resolved] (KAFKA-7385) Log cleaner crashes when empty batches are retained with idempotent or transactional producers

[ https://issues.apache.org/jira/browse/KAFKA-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7385. Resolution: Fixed Fix Version/s: 2.0.1 > Log cleaner crashes when empty batches are

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

Jason Gustafson created KAFKA-7383: -- Summary: Verify leader epoch in produce requests (KIP-359) Key: KAFKA-7383 URL: https://issues.apache.org/jira/browse/KAFKA-7383 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-7369) Retry when possible in AdminClient.listConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7369. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 > Retry when possibl

[jira] [Created] (KAFKA-7369) Retry when possible in AdminClient.listConsumerGroups

Jason Gustafson created KAFKA-7369: -- Summary: Retry when possible in AdminClient.listConsumerGroups Key: KAFKA-7369 URL: https://issues.apache.org/jira/browse/KAFKA-7369 Project: Kafka Issue

[jira] [Resolved] (KAFKA-7128) Lagging high watermark can lead to committed data loss after ISR expansion

[ https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7128. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 1.

[jira] [Resolved] (KAFKA-7347) Wrong error code returned for OffsetsForLeaderEpoch from non-replica

[ https://issues.apache.org/jira/browse/KAFKA-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7347. Resolution: Fixed Fix Version/s: 2.1.0 > Wrong error code returned for OffsetsForLea

[jira] [Created] (KAFKA-7347) Wrong error code returned for OffsetsForLeaderEpoch from follower/non-replica

Jason Gustafson created KAFKA-7347: -- Summary: Wrong error code returned for OffsetsForLeaderEpoch from follower/non-replica Key: KAFKA-7347 URL: https://issues.apache.org/jira/browse/KAFKA-7347 Proje

[jira] [Resolved] (KAFKA-7139) Support to exclude the internal topics in kafka-topics.sh command

[ https://issues.apache.org/jira/browse/KAFKA-7139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7139. Resolution: Fixed Fix Version/s: 2.1.0 > Support to exclude the internal topics in k

[jira] [Created] (KAFKA-7335) Store clusterId locally to ensure broker joins the right cluster

Jason Gustafson created KAFKA-7335: -- Summary: Store clusterId locally to ensure broker joins the right cluster Key: KAFKA-7335 URL: https://issues.apache.org/jira/browse/KAFKA-7335 Project: Kafka

[jira] [Created] (KAFKA-7333) Protocol changes for KIP-320

Jason Gustafson created KAFKA-7333: -- Summary: Protocol changes for KIP-320 Key: KAFKA-7333 URL: https://issues.apache.org/jira/browse/KAFKA-7333 Project: Kafka Issue Type: Bug Re

[jira] [Resolved] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5891. Resolution: Fixed Fix Version/s: 2.0.1 1.1.2 1.

[jira] [Resolved] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7278. Resolution: Fixed Fix Version/s: 2.0.1 > replaceSegments() should not call asyncDele

[jira] [Resolved] (KAFKA-7298) Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer

[ https://issues.apache.org/jira/browse/KAFKA-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7298. Resolution: Fixed Fix Version/s: 2.0.1 > Concurrent DeleteRecords can lead to fatal

[jira] [Resolved] (KAFKA-7296) Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit

[ https://issues.apache.org/jira/browse/KAFKA-7296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7296. Resolution: Fixed > Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit > -

[jira] [Created] (KAFKA-7298) Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer

Jason Gustafson created KAFKA-7298: -- Summary: Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer Key: KAFKA-7298 URL: https://issues.apache.org/jira/browse/KAFKA-7298 Project:

[jira] [Created] (KAFKA-7296) Producer should handler COORDINATOR_LOADING error in TxnOffsetCommit

Jason Gustafson created KAFKA-7296: -- Summary: Producer should handler COORDINATOR_LOADING error in TxnOffsetCommit Key: KAFKA-7296 URL: https://issues.apache.org/jira/browse/KAFKA-7296 Project: Kafka

[jira] [Resolved] (KAFKA-7164) Follower should truncate after every leader epoch change

[ https://issues.apache.org/jira/browse/KAFKA-7164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7164. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 1.

[jira] [Resolved] (KAFKA-7140) Remove deprecated poll usages

[ https://issues.apache.org/jira/browse/KAFKA-7140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7140. Resolution: Fixed > Remove deprecated poll usages > - > >

[jira] [Resolved] (KAFKA-6751) Make max.connections.per.ip.overrides a dynamic config

[ https://issues.apache.org/jira/browse/KAFKA-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6751. Resolution: Fixed > Make max.connections.per.ip.overrides a dynamic config > --

[jira] [Created] (KAFKA-7234) Allow auto leader rebalance during partition reassignment

Jason Gustafson created KAFKA-7234: -- Summary: Allow auto leader rebalance during partition reassignment Key: KAFKA-7234 URL: https://issues.apache.org/jira/browse/KAFKA-7234 Project: Kafka I

[jira] [Created] (KAFKA-7211) MM should handle timeouts in commitSync

Jason Gustafson created KAFKA-7211: -- Summary: MM should handle timeouts in commitSync Key: KAFKA-7211 URL: https://issues.apache.org/jira/browse/KAFKA-7211 Project: Kafka Issue Type: Improve

[jira] [Resolved] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6014. Resolution: Resolved We changed the behavior of the consumer in KAFKA-6829 so that unknown

[jira] [Resolved] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4994. Resolution: Fixed Fix Version/s: 2.1.0 > Fix findbugs warning about OffsetStorageWri

[jira] [Resolved] (KAFKA-7170) NPE in ConsumerGroupCommand when describe consumer group

[ https://issues.apache.org/jira/browse/KAFKA-7170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7170. Resolution: Duplicate Resolving as duplicate. Please continue discussion in KAFKA-7044 if n

[jira] [Created] (KAFKA-7173) Update BrokerApiVersionsCommand to use new AdminClient

Jason Gustafson created KAFKA-7173: -- Summary: Update BrokerApiVersionsCommand to use new AdminClient Key: KAFKA-7173 URL: https://issues.apache.org/jira/browse/KAFKA-7173 Project: Kafka Issu

[jira] [Created] (KAFKA-7164) Follower should truncate after every leader epoch change

Jason Gustafson created KAFKA-7164: -- Summary: Follower should truncate after every leader epoch change Key: KAFKA-7164 URL: https://issues.apache.org/jira/browse/KAFKA-7164 Project: Kafka Is

[jira] [Resolved] (KAFKA-7130) EOFException after rolling log segment

[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7130. Resolution: Duplicate > EOFException after rolling log segment > --

[jira] [Resolved] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2933. Resolution: Cannot Reproduce It's been a long time since we've seen this, so I will close.

[jira] [Created] (KAFKA-7128) Lagging high watermark can lead to committed data loss after ISR expansion

Jason Gustafson created KAFKA-7128: -- Summary: Lagging high watermark can lead to committed data loss after ISR expansion Key: KAFKA-7128 URL: https://issues.apache.org/jira/browse/KAFKA-7128 Project:

[jira] [Resolved] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

[ https://issues.apache.org/jira/browse/KAFKA-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7091. Resolution: Fixed > AdminClient should handle FindCoordinatorResponse errors >

[jira] [Resolved] (KAFKA-7067) ConnectRestApiTest fails assertion

[ https://issues.apache.org/jira/browse/KAFKA-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7067. Resolution: Fixed > ConnectRestApiTest fails assertion > --

[jira] [Resolved] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6975. Resolution: Fixed Fix Version/s: (was: 1.1.1) (was: 1.0.2)

[jira] [Resolved] (KAFKA-7050) Decrease consumer request timeout to 30s

[ https://issues.apache.org/jira/browse/KAFKA-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7050. Resolution: Fixed > Decrease consumer request timeout to 30s >

[jira] [Created] (KAFKA-7050) Decrease consumer request timeout to 30s

Jason Gustafson created KAFKA-7050: -- Summary: Decrease consumer request timeout to 30s Key: KAFKA-7050 URL: https://issues.apache.org/jira/browse/KAFKA-7050 Project: Kafka Issue Type: Improv

[jira] [Resolved] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6743. Resolution: Fixed Fix Version/s: 2.0.0 > ConsumerPerformance fails to consume all me

[jira] [Created] (KAFKA-6979) Add max.block.ms to consumer for default behavior

Jason Gustafson created KAFKA-6979: -- Summary: Add max.block.ms to consumer for default behavior Key: KAFKA-6979 URL: https://issues.apache.org/jira/browse/KAFKA-6979 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-3834) Consumer should not block in poll on coordinator discovery

[ https://issues.apache.org/jira/browse/KAFKA-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3834. Resolution: Fixed Fix Version/s: 2.0.0 Fixed by KIP-266 > Consumer should not block

<    3   4   5   6   7   8   9   10   11   12   >