[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] [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] [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-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-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] [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] [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] [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] [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-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-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] [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] [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-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-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-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] [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-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] [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-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-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-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-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] [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-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-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-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-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] [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] [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-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-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] [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-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] [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-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] [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-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-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-7824) Require member.id for initial join group request

[ https://issues.apache.org/jira/browse/KAFKA-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7824. Resolution: Fixed Fix Version/s: 2.2.0 > Require member.id for initial join group re

[jira] [Created] (KAFKA-7831) Consumer SubscriptionState missing synchronization

Jason Gustafson created KAFKA-7831: -- Summary: Consumer SubscriptionState missing synchronization Key: KAFKA-7831 URL: https://issues.apache.org/jira/browse/KAFKA-7831 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-7738) Track partition leader epochs in client metadata

[ https://issues.apache.org/jira/browse/KAFKA-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7738. Resolution: Fixed Fix Version/s: 2.2.0 > Track partition leader epochs in client met

[jira] [Resolved] (KAFKA-6857) LeaderEpochFileCache.endOffsetFor() should check for UNDEFINED_EPOCH explicitly

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

[jira] [Resolved] (KAFKA-6867) Typos in upgrade.html

[ https://issues.apache.org/jira/browse/KAFKA-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6867. Resolution: Fixed > Typos in upgrade.html > - > > Key: K

[jira] [Created] (KAFKA-6879) Controller deadlock following session expiration

Jason Gustafson created KAFKA-6879: -- Summary: Controller deadlock following session expiration Key: KAFKA-6879 URL: https://issues.apache.org/jira/browse/KAFKA-6879 Project: Kafka Issue Type

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

Jason Gustafson created KAFKA-6880: -- Summary: Zombie replicas must be fenced Key: KAFKA-6880 URL: https://issues.apache.org/jira/browse/KAFKA-6880 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

Jason Gustafson created KAFKA-6884: -- Summary: ConsumerGroupCommand should use new AdminClient Key: KAFKA-6884 URL: https://issues.apache.org/jira/browse/KAFKA-6884 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream

[ https://issues.apache.org/jira/browse/KAFKA-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6292. Resolution: Fixed > KafkaConsumer ran into Unknown error fetching data for topic-partition c

[jira] [Resolved] (KAFKA-6299) Fix AdminClient error handling when metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6299. Resolution: Fixed Fix Version/s: 2.0.0 > Fix AdminClient error handling when metadata

[jira] [Resolved] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

[ https://issues.apache.org/jira/browse/KAFKA-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6893. Resolution: Fixed Fix Version/s: 1.1.1 > Processors created after acceptor started wh

[jira] [Resolved] (KAFKA-6394) Prevent misconfiguration of advertised listeners

[ https://issues.apache.org/jira/browse/KAFKA-6394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6394. Resolution: Fixed Fix Version/s: 2.0.0 > Prevent misconfiguration of advertised liste

[jira] [Resolved] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock

[ https://issues.apache.org/jira/browse/KAFKA-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6917. Resolution: Fixed > Request handler deadlocks attempting to acquire group metadata lock > --

[jira] [Resolved] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6911. Resolution: Fixed > Incorrect check for keystore/truststore dynamic update > ---

[jira] [Resolved] (KAFKA-2061) Offer a --version flag to print the kafka version

[ https://issues.apache.org/jira/browse/KAFKA-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2061. Resolution: Fixed Fix Version/s: 2.0.0 > Offer a --version flag to print the kafka ve

[jira] [Created] (KAFKA-6949) NoSuchElementException in ReplicaManager

Jason Gustafson created KAFKA-6949: -- Summary: NoSuchElementException in ReplicaManager Key: KAFKA-6949 URL: https://issues.apache.org/jira/browse/KAFKA-6949 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-2951) Additional authorization test cases

[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2951. Resolution: Fixed Fix Version/s: 2.0.0 > Additional authorization test cases > --

[jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5697. Resolution: Fixed Fix Version/s: 2.0.0 > StreamThread.shutdown() need to interrupt th

[jira] [Resolved] (KAFKA-6916) AdminClient does not refresh metadata on broker failure

[ https://issues.apache.org/jira/browse/KAFKA-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6916. Resolution: Fixed > AdminClient does not refresh metadata on broker failure > -

[jira] [Resolved] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6608. Resolution: Fixed Fix Version/s: 2.0.0 > Add TimeoutException to KafkaConsumer#posit

[jira] [Resolved] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4879. Resolution: Fixed This is addressed by KIP-266. > KafkaConsumer.position may hang forever

[jira] [Resolved] (KAFKA-2391) Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout

[ https://issues.apache.org/jira/browse/KAFKA-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2391. Resolution: Fixed Fix Version/s: 2.0.0 Fixed by KIP-266 > Blocking call such as pos

[jira] [Resolved] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1894. Resolution: Fixed Fixed by KIP-266 (and many subsequent changes which gradually introduced

[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

[jira] [Resolved] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5065. Resolution: Fixed Fixed by KIP-266 > AbstractCoordinator.ensureCoordinatorReady() stuck in

[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-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-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-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] [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-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-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] [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-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] [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] [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] [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] [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] [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-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] [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] [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] [Resolved] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6250. Resolution: Fixed Assignee: Gavrie Philipson > Kafka Connect requires permission to cr

[jira] [Resolved] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6366. Resolution: Fixed > StackOverflowError in kafka-coordinator-heartbeat-thread > -

[jira] [Resolved] (KAFKA-6287) Inconsistent protocol type for empty consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6287. Resolution: Fixed > Inconsistent protocol type for empty consumer groups > -

[jira] [Resolved] (KAFKA-6421) consumer group can't show when use kafka-consumer-groups tool if the leader of __consumer_offsets partition for this group changed

[ https://issues.apache.org/jira/browse/KAFKA-6421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6421. Resolution: Fixed > consumer group can't show when use kafka-consumer-groups tool if the lea

[jira] [Resolved] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6336. Resolution: Fixed > when using assign() with kafka consumer the KafkaConsumerGroup command d

[jira] [Created] (KAFKA-6480) Add config to enforce max fetch size on the broker

Jason Gustafson created KAFKA-6480: -- Summary: Add config to enforce max fetch size on the broker Key: KAFKA-6480 URL: https://issues.apache.org/jira/browse/KAFKA-6480 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0

[ https://issues.apache.org/jira/browse/KAFKA-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6429. Resolution: Fixed > dirtyNonActiveSegments in `cleanableOffsets` should only be created when

[jira] [Resolved] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files

[ https://issues.apache.org/jira/browse/KAFKA-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4897. Resolution: Fixed > LogCleaner#cleanSegments should not ignore failures to delete files > --

[jira] [Resolved] (KAFKA-4991) KerberosLogin#login should probably be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-4991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4991. Resolution: Fixed Assignee: Manikumar (was: Colin P. McCabe) > KerberosLogin#login sh

[jira] [Resolved] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic

[ https://issues.apache.org/jira/browse/KAFKA-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6467. Resolution: Fixed Reviewer: Jason Gustafson (was: Ewen Cheslack-Postava) > Enforce la

[jira] [Resolved] (KAFKA-6418) AdminClient should handle empty or null topic names better

[ https://issues.apache.org/jira/browse/KAFKA-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6418. Resolution: Fixed Fix Version/s: 1.1.0 > AdminClient should handle empty or null topi

[jira] [Resolved] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

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

[jira] [Created] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

Jason Gustafson created KAFKA-6527: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig Key: KAFKA-6527 URL: https://issues.apache.org/jira/browse/KAFKA-6527 Projec

[jira] [Created] (KAFKA-6528) Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize

Jason Gustafson created KAFKA-6528: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize Key: KAFKA-6528 URL: https://issues.apache.org/jira/browse/KAFKA-6528 Project:

[jira] [Resolved] (KAFKA-6494) Extend ConfigCommand to update broker config using new AdminClient

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

[jira] [Created] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2

Jason Gustafson created KAFKA-6530: -- Summary: Use actual first offset of messages when rolling log segment for magic v2 Key: KAFKA-6530 URL: https://issues.apache.org/jira/browse/KAFKA-6530 Project:

[jira] [Resolved] (KAFKA-6515) Add toString() method to kafka connect Field class

[ https://issues.apache.org/jira/browse/KAFKA-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6515. Resolution: Fixed Fix Version/s: 1.2.0 > Add toString() method to kafka connect Field

[jira] [Created] (KAFKA-6540) Consumer lag metric is not updated when a partition is paused

Jason Gustafson created KAFKA-6540: -- Summary: Consumer lag metric is not updated when a partition is paused Key: KAFKA-6540 URL: https://issues.apache.org/jira/browse/KAFKA-6540 Project: Kafka

[jira] [Resolved] (KAFKA-6504) Connect: Some per-task-metrics not working

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6504. Resolution: Fixed Fix Version/s: 1.1.0 > Connect: Some per-task-metrics not working >

  1   2   3   4   5   6   7   8   9   10   >