[jira] [Resolved] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

2020-02-23 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9541. Resolution: Fixed > Flaky Test > DescribeConsumerGro

[jira] [Resolved] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

2020-02-23 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9530. Resolution: Fixed > Flaky T

[jira] [Created] (KAFKA-9596) Hanging test case `testMaxLogCompactionLag`

2020-02-21 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9596: -- Summary: Hanging test case `testMaxLogCompactionLag` Key: KAFKA-9596 URL: https://issues.apache.org/jira/browse/KAFKA-9596 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-9577) Client encountering SASL_HANDSHAKE protocol version errors on 2.5 / trunk

2020-02-21 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9577. Resolution: Fixed > Client encountering SASL_HANDSHAKE protocol version errors on

[jira] [Created] (KAFKA-9595) Config tool should use admin client's incremental config API

2020-02-21 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9595: -- Summary: Config tool should use admin client's incremental config API Key: KAFKA-9595 URL: https://issues.apache.org/jira/browse/KAFKA-9595 Project:

[jira] [Resolved] (KAFKA-9206) Consumer should handle `CORRUPT_MESSAGE` error code in fetch response

2020-02-21 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9206. Fix Version/s: 2.6.0 Resolution: Fixed > Consumer should handle `CORRUPT_MESS

[jira] [Resolved] (KAFKA-9544) Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride`

2020-02-19 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9544. Resolution: Fixed > Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverr

[jira] [Resolved] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

2020-02-16 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9535. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution

[jira] [Resolved] (KAFKA-8805) Bump producer epoch following recoverable errors

2020-02-15 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8805. Fix Version/s: 2.5.0 Resolution: Fixed > Bump producer epoch following recovera

Re: [DISCUSS] KIP-570: Add leader epoch in StopReplicaRequest

2020-02-14 Thread Jason Gustafson
Hey David, Thanks, it makes sense to prevent reordering, especially for the case of reassignment. When a topic is deleted, however, I am not sure we will have a bumped epoch to send. I guess for that case, we could send a sentinel which would take the existing semantics of overriding any existing

[jira] [Created] (KAFKA-9553) Transaction state loading metric does not count total loading time

2020-02-13 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9553: -- Summary: Transaction state loading metric does not count total loading time Key: KAFKA-9553 URL: https://issues.apache.org/jira/browse/KAFKA-9553 Project: Kafka

[jira] [Resolved] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

2020-02-12 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9538. Resolution: Fixed > Flaky Test `testResetOffsetsExportImportP

[jira] [Created] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

2020-02-12 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9545: -- Summary: Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` Key: KAFKA-9545 URL: https://issues.apache.org/jira/browse/KAFKA-9545 Project

[jira] [Created] (KAFKA-9544) Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride`

2020-02-12 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9544: -- Summary: Flaky Test `KafkaAdminClientTest.testDefaultApiTimeoutOverride` Key: KAFKA-9544 URL: https://issues.apache.org/jira/browse/KAFKA-9544 Project: Kafka

[jira] [Resolved] (KAFKA-9499) Improve deletion process by batching more aggressively

2020-02-12 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9499. Fix Version/s: 2.5.0 Resolution: Fixed > Improve deletion process by batching m

[jira] [Created] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

2020-02-11 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9538: -- Summary: Flaky Test `testResetOffsetsExportImportPlan` Key: KAFKA-9538 URL: https://issues.apache.org/jira/browse/KAFKA-9538 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

2020-02-11 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8211. Resolution: Fixed Closing this one since new failures do not match the stacktrace. I&#x

[jira] [Resolved] (KAFKA-9507) AdminClient should check for missing committed offsets

2020-02-07 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9507. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution

[jira] [Created] (KAFKA-9507) AdminClient should check for missing committed offsets

2020-02-05 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9507: -- Summary: AdminClient should check for missing committed offsets Key: KAFKA-9507 URL: https://issues.apache.org/jira/browse/KAFKA-9507 Project: Kafka

[jira] [Resolved] (KAFKA-9261) NPE when updating client metadata

2020-02-05 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9261. Resolution: Fixed > NPE when updating client metad

[jira] [Resolved] (KAFKA-9491) Fast election during reassignment can lead to replica fetcher failures

2020-02-04 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9491. Resolution: Fixed > Fast election during reassignment can lead to replica fetcher failu

[jira] [Created] (KAFKA-9491) Fast election during reassignment can lead to replica fetcher failures

2020-02-01 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9491: -- Summary: Fast election during reassignment can lead to replica fetcher failures Key: KAFKA-9491 URL: https://issues.apache.org/jira/browse/KAFKA-9491 Project

[jira] [Resolved] (KAFKA-9437) KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies

2020-01-31 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9437. Fix Version/s: 2.5.0 Resolution: Fixed > KIP-559: Make the Kafka Proto

[jira] [Resolved] (KAFKA-8503) Implement default.api.timeout.ms for AdminClient

2020-01-30 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8503. Fix Version/s: 2.5.0 Resolution: Fixed > Implement default.api.timeout.ms

[jira] [Created] (KAFKA-9484) Unnecessary LeaderAndIsr update following reassignment completion

2020-01-30 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9484: -- Summary: Unnecessary LeaderAndIsr update following reassignment completion Key: KAFKA-9484 URL: https://issues.apache.org/jira/browse/KAFKA-9484 Project: Kafka

[jira] [Resolved] (KAFKA-9040) Implement --all option for describing configs

2020-01-29 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9040. Fix Version/s: 2.5.0 Resolution: Fixed > Implement --all option for describ

[jira] [Created] (KAFKA-9479) Describe consumer group --all-groups shows header for each entry

2020-01-28 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9479: -- Summary: Describe consumer group --all-groups shows header for each entry Key: KAFKA-9479 URL: https://issues.apache.org/jira/browse/KAFKA-9479 Project: Kafka

Re: [VOTE] KIP-546: Add quota-specific APIs to the Admin Client, redux

2020-01-28 Thread Jason Gustafson
+1 Nice to see this API finally resolved. -Jason On Tue, Jan 28, 2020 at 4:30 AM Rajini Sivaram wrote: > +1 (binding) > > Thanks for the KIP, Brian! > > Regards, > > Rajini > > On Mon, Jan 27, 2020 at 10:35 PM Colin McCabe wrote: > > > Thanks, Brian. > > > > +1 (binding) > > > > best, > > Col

[jira] [Resolved] (KAFKA-9254) Updating Kafka Broker configuration dynamically twice reverts log configuration to default

2020-01-24 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9254. Fix Version/s: 2.4.1 2.3.2 2.2.3

Re: [VOTE] KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics

2020-01-23 Thread Jason Gustafson
ata.max.age.ms for determining refresh period (which is an > actual > period). > > I've updated the docs. > > Thanks, > Brian > > On Wed, Jan 22, 2020 at 6:19 PM Jason Gustafson > wrote: > > > Thanks for the proposal. Looks good overall. I wanted

[jira] [Created] (KAFKA-9470) Hanging test case `testBlockOnRequestCompletionFromStateChangeHandler`

2020-01-23 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9470: -- Summary: Hanging test case `testBlockOnRequestCompletionFromStateChangeHandler` Key: KAFKA-9470 URL: https://issues.apache.org/jira/browse/KAFKA-9470 Project

[jira] [Resolved] (KAFKA-7737) Consolidate InitProducerId API

2020-01-23 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7737. Fix Version/s: 2.5.0 Resolution: Fixed > Consolidate InitProducerId

Re: [VOTE] KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics

2020-01-22 Thread Jason Gustafson
Thanks for the proposal. Looks good overall. I wanted to suggest a possible name change. I was considering something like `idle.metadata.expiration.ms` or maybe `metadata.max.idle.ms`. Thoughts? -Jason On Tue, Jan 21, 2020 at 11:38 AM Guozhang Wang wrote: > Got it. > > I was proposing that we

[jira] [Resolved] (KAFKA-9418) Add new sendOffsets API to include consumer group metadata

2020-01-22 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9418. Fix Version/s: 2.5.0 Resolution: Fixed > Add new sendOffsets API to incl

Re: [VOTE] KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies

2020-01-21 Thread Jason Gustafson
nse. Let me update the KIP. > > Thanks, > David > > On Tue, Jan 21, 2020 at 12:52 PM Jason Gustafson > wrote: > > > Hi David, > > > > Just one question. In addition to including the protocol type, I'm > > wondering if there is value in adding the p

Re: [VOTE] KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies

2020-01-21 Thread Jason Gustafson
Hi David, Just one question. In addition to including the protocol type, I'm wondering if there is value in adding the protocol name to SyncGroup? This would potentially give you the ability to parse the "user data" field in the consumer group schema. Thanks, Jason On Tue, Jan 21, 2020 at 9:35 A

Re: [DISCUSS] KIP-546: Add quota-specific APIs to the Admin Client, redux

2020-01-21 Thread Jason Gustafson
Hi Brian, Thanks for the proposal! I have a couple comments/questions: 1. I'm having a hard time understanding the point of `QuotaEntity.Type`. It sounds like this might be just for convenience since the APIs are using string types. If so, I think it's a bit misleading to represent it as an enum.

[jira] [Resolved] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes

2020-01-17 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9338. Fix Version/s: 2.5.0 Resolution: Fixed Marking this just as 2.5 for now. If we

[jira] [Resolved] (KAFKA-9329) KafkaController::replicasAreValid should return error

2020-01-17 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9329. Fix Version/s: 2.5.0 Resolution: Fixed > KafkaController::replicasAreValid sho

[jira] [Resolved] (KAFKA-9449) Producer's BufferPool may block the producer from closing.

2020-01-17 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9449. Fix Version/s: 2.4.1 Resolution: Fixed > Producer's BufferPool may b

[jira] [Resolved] (KAFKA-9235) Transaction state not cleaned up following StopReplica request

2020-01-16 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9235. Fix Version/s: 2.4.1 Resolution: Fixed > Transaction state not cleaned up follow

[jira] [Resolved] (KAFKA-8832) We should limit the maximum size read by a fetch request on the kafka server.

2020-01-16 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8832. Resolution: Fixed This is resolved by https://cwiki.apache.org/confluence/display/KAFKA

[jira] [Resolved] (KAFKA-9410) Make groupId Optional in KafkaConsumer

2020-01-15 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9410. Resolution: Fixed > Make groupId Optional in KafkaConsu

[jira] [Resolved] (KAFKA-9420) Bump APIs to enable flexible versions

2020-01-14 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9420. Fix Version/s: 2.5.0 Resolution: Fixed > Bump APIs to enable flexible versi

[jira] [Created] (KAFKA-9420) Bump APIs to enable flexible versions

2020-01-13 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9420: -- Summary: Bump APIs to enable flexible versions Key: KAFKA-9420 URL: https://issues.apache.org/jira/browse/KAFKA-9420 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-9363) Admin Script "kafka-topics" doesn't confirm on successful creation

2020-01-11 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9363. Resolution: Fixed > Admin Script "kafka-topics" doesn't confirm on s

[jira] [Resolved] (KAFKA-9396) Use JDK emptyIterator in ConnectHeaders Class

2020-01-11 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9396. Resolution: Fixed > Use JDK emptyIterator in ConnectHeaders Cl

[jira] [Resolved] (KAFKA-8617) Replace EndTxn request/response with automated protocol

2020-01-09 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8617. Fix Version/s: 2.5.0 Resolution: Fixed > Replace EndTxn request/response w

[jira] [Resolved] (KAFKA-8242) Exception in ReplicaFetcher blocks replication of all other partitions

2020-01-09 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8242. Resolution: Fixed Marking this as resolved. We believe we having fixed the cause of the

[jira] [Resolved] (KAFKA-9144) Early expiration of producer state can cause coordinator epoch to regress

2020-01-09 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9144. Fix Version/s: 2.4.1 Resolution: Fixed > Early expiration of producer state

[jira] [Resolved] (KAFKA-9287) Transaction completion may block unnecessarily after abortable error

2020-01-09 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9287. Fix Version/s: 2.5.0 Resolution: Fixed > Transaction completion may bl

[jira] [Resolved] (KAFKA-8988) Replace CreatePartitions request/response with automated protocol

2020-01-08 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8988. Fix Version/s: 2.5.0 Resolution: Fixed > Replace CreatePartitions request/respo

[jira] [Resolved] (KAFKA-9065) Loading offsets and group metadata loops forever

2020-01-07 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9065. Fix Version/s: 2.4.1 Resolution: Fixed > Loading offsets and group metadata lo

[jira] [Resolved] (KAFKA-9330) Calling AdminClient.close in the AdminClient completion callback causes deadlock

2020-01-07 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9330. Fix Version/s: 2.5.0 Resolution: Fixed > Calling AdminClient.close in

[jira] [Resolved] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder

2020-01-03 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9293. Fix Version/s: 2.4.1 Resolution: Fixed > NPE in DumpLogSegments with --offs

[jira] [Resolved] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic

2020-01-02 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8933. Fix Version/s: 2.4.1 Resolution: Fixed > An unhandled SSL handshake exception

[jira] [Reopened] (KAFKA-9350) IllegalStateException when materializing transactional offset commits

2020-01-02 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-9350: > IllegalStateException when materializing transactional offset comm

[jira] [Resolved] (KAFKA-9350) IllegalStateException when materializing transactional offset commits

2020-01-02 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9350. Fix Version/s: 2.4.1 Resolution: Fixed > IllegalStateException when materializ

[jira] [Created] (KAFKA-9350) IllegalStateException when materializing transactional offset commits

2019-12-30 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9350: -- Summary: IllegalStateException when materializing transactional offset commits Key: KAFKA-9350 URL: https://issues.apache.org/jira/browse/KAFKA-9350 Project

[jira] [Created] (KAFKA-9348) Broker shutdown during controller initialization can lead to zombie broker

2019-12-30 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9348: -- Summary: Broker shutdown during controller initialization can lead to zombie broker Key: KAFKA-9348 URL: https://issues.apache.org/jira/browse/KAFKA-9348 Project

[jira] [Resolved] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR

2019-12-30 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-661. --- Resolution: Fixed This patch is fixed by KIP-320, which adds leader epoch validation to the

[jira] [Resolved] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

2019-12-30 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3410. Resolution: Resolved I am going to go ahead and close this since it has become a bit dated

[jira] [Created] (KAFKA-9347) Detect deleted log directory before becoming leader

2019-12-30 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9347: -- Summary: Detect deleted log directory before becoming leader Key: KAFKA-9347 URL: https://issues.apache.org/jira/browse/KAFKA-9347 Project: Kafka Issue

[jira] [Resolved] (KAFKA-3944) After the broker restart, fetchers stopped due to a delayed controlled shutdown message

2019-12-30 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3944. Resolution: Fixed > After the broker restart, fetchers stopped due to a delayed control

[jira] [Resolved] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

2019-12-30 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1342. Resolution: Fixed > Slow controlled shutdowns can result in stale shutdown reque

[jira] [Resolved] (KAFKA-9232) Coordinator new member heartbeat completion does not work for JoinGroup v3

2019-12-23 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9232. Fix Version/s: 2.4.1 2.3.2 2.2.3

[jira] [Resolved] (KAFKA-9307) Transaction coordinator could be left in unknown state after ZK session timeout

2019-12-23 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9307. Resolution: Fixed > Transaction coordinator could be left in unknown state after

[jira] [Created] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder

2019-12-11 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9293: -- Summary: NPE in DumpLogSegments with --offsets-decoder Key: KAFKA-9293 URL: https://issues.apache.org/jira/browse/KAFKA-9293 Project: Kafka Issue Type

[jira] [Created] (KAFKA-9287) Transaction completion may block unnecessarily after abortable error

2019-12-07 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9287: -- Summary: Transaction completion may block unnecessarily after abortable error Key: KAFKA-9287 URL: https://issues.apache.org/jira/browse/KAFKA-9287 Project

Re: [VOTE] 2.4.0 RC3

2019-12-06 Thread Jason Gustafson
Hi Manikumar, We've gotten to the bottom of https://issues.apache.org/jira/browse/KAFKA-9212 and I think it should be a blocker. The impact of this bug is that consumers cannot make progress while a reassignment is in progress. The problem is missing logic in the controller to update its metadata

[jira] [Resolved] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever

2019-12-04 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9251. Resolution: Fixed > Describing a non consumer group with the Admin API hangs fore

[jira] [Resolved] (KAFKA-9190) Server leaves connections with expired authentication sessions open

2019-12-04 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9190. Fix Version/s: 2.3.2 2.2.3 2.4.0 Resolution

[jira] [Created] (KAFKA-9261) NPE when updating client metadata

2019-12-02 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9261: -- Summary: NPE when updating client metadata Key: KAFKA-9261 URL: https://issues.apache.org/jira/browse/KAFKA-9261 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-9235) Transaction state not cleaned up following StopReplica request

2019-11-26 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9235: -- Summary: Transaction state not cleaned up following StopReplica request Key: KAFKA-9235 URL: https://issues.apache.org/jira/browse/KAFKA-9235 Project: Kafka

[jira] [Created] (KAFKA-9232) Coordinator heartbeat completion does not work for JoinGroup v3

2019-11-26 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9232: -- Summary: Coordinator heartbeat completion does not work for JoinGroup v3 Key: KAFKA-9232 URL: https://issues.apache.org/jira/browse/KAFKA-9232 Project: Kafka

Re: [VOTE] KIP-533: Add default api timeout to AdminClient

2019-11-26 Thread Jason Gustafson
to > be > > updated as it currently mentions "request timeout". An example from > > CreateTopicsOptions: > > > > "Set the request timeout in milliseconds for this operation or {@code > null} > > if the default request timeout for the AdminClient should

[jira] [Resolved] (KAFKA-9229) initTransactions() fails when running new producer against an old server

2019-11-26 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9229. Resolution: Fixed > initTransactions() fails when running new producer against an

[VOTE] KIP-533: Add default api timeout to AdminClient

2019-11-22 Thread Jason Gustafson
I'd like to start a vote on KIP-533: https://cwiki.apache.org/confluence/display/KAFKA/KIP-533%3A+Add+default+api+timeout+to+AdminClient . +1 from me Thanks, Jason

[jira] [Resolved] (KAFKA-8509) Add downgrade system tests

2019-11-22 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8509. Resolution: Fixed > Add downgrade system te

Re: [DISCUSS] KIP-533: Add default api timeout to AdminClient

2019-11-20 Thread Jason Gustafson
This seems not very controversial, so I will go ahead and move to a vote in the next couple days. Thanks, Jason On Wed, Nov 13, 2019 at 10:23 AM Jason Gustafson wrote: > Hey Colin, > > Thanks for the suggestions. I've clarified the use of the API overrides > and the reque

Re: Subject: [VOTE] 2.2.2 RC2

2019-11-19 Thread Jason Gustafson
+1 (binding) Verified release notes and ran through the 2.12 quickstart. Thanks Randall! On Thu, Nov 14, 2019 at 8:52 PM Gwen Shapira wrote: > +1 (binding) > > Thanks Randall. Verified signatures and tests. > > On Fri, Oct 25, 2019 at 7:10 AM Randall Hauch wrote: > > > > Hello all, we identif

[jira] [Resolved] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

2019-11-18 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9198. Fix Version/s: 2.4.0 Resolution: Fixed The PR has been merged. I meant to change

[jira] [Resolved] (KAFKA-8571) Not complete delayed produce requests when processing StopReplicaRequest causing high produce latency for acks=all

2019-11-18 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8571. Resolution: Fixed > Not complete delayed produce requests when process

[jira] [Reopened] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

2019-11-18 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-9198: > StopReplica handler should complete pending purgatory operati

[jira] [Created] (KAFKA-9206) Consumer should handle `CORRUPT_MESSAGE` error code in fetch response

2019-11-18 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9206: -- Summary: Consumer should handle `CORRUPT_MESSAGE` error code in fetch response Key: KAFKA-9206 URL: https://issues.apache.org/jira/browse/KAFKA-9206 Project

Re: [DISCUSS] KIP-536: Propagate broker timestamp to Admin API

2019-11-18 Thread Jason Gustafson
n a set of brokers in the response, adding a brokerId field to > > identify which > > broker a specific broker status response is associated with seems > straight > > forward. > > > > I’ll start writing a proposal so that we have something concrete to > > di

[jira] [Created] (KAFKA-9199) Improve handling of out of sequence errors lower than last acked sequence

2019-11-16 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9199: -- Summary: Improve handling of out of sequence errors lower than last acked sequence Key: KAFKA-9199 URL: https://issues.apache.org/jira/browse/KAFKA-9199 Project

[jira] [Resolved] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

2019-11-16 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9198. Resolution: Duplicate > StopReplica handler should complete pending purgatory operati

[jira] [Created] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

2019-11-16 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9198: -- Summary: StopReplica handler should complete pending purgatory operations Key: KAFKA-9198 URL: https://issues.apache.org/jira/browse/KAFKA-9198 Project: Kafka

[jira] [Created] (KAFKA-9196) Records exposed before advancement of high watermark after segment roll

2019-11-15 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9196: -- Summary: Records exposed before advancement of high watermark after segment roll Key: KAFKA-9196 URL: https://issues.apache.org/jira/browse/KAFKA-9196 Project

[jira] [Created] (KAFKA-9190) Server leaves connections with expired authentication sessions open

2019-11-14 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9190: -- Summary: Server leaves connections with expired authentication sessions open Key: KAFKA-9190 URL: https://issues.apache.org/jira/browse/KAFKA-9190 Project

Re: [DISCUSS] KIP-501 Avoid out-of-sync or offline partitions when follower fetch requests not processed in time

2019-11-13 Thread Jason Gustafson
Hi Satish, Thanks for the KIP. I'm wondering how much of this problem can be addressed just by increasing the replication max lag? That was one of the purposes of KIP-537 (the default increased from 10s to 30s). Also, the new configurations seem quite low level. I think they will be hard for user

[jira] [Resolved] (KAFKA-8710) InitProducerId changes for KIP-360

2019-11-13 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8710. Fix Version/s: 2.5.0 Resolution: Fixed > InitProducerId changes for KIP-

[jira] [Created] (KAFKA-9183) SaslSslAdminClientIntegrationTest takes too long to execute

2019-11-13 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9183: -- Summary: SaslSslAdminClientIntegrationTest takes too long to execute Key: KAFKA-9183 URL: https://issues.apache.org/jira/browse/KAFKA-9183 Project: Kafka

Re: [DISCUSS] KIP-533: Add default api timeout to AdminClient

2019-11-13 Thread Jason Gustafson
2:01 PM Ismael Juma wrote: > Thanks for the KIP, this makes sense to me. It will be good to align the > AdminClient better with the consumer and producer when it comes to > timeouts. > > Ismael > > On Wed, Oct 9, 2019 at 12:06 PM Jason Gustafson > wrote: > > >

Re: [DISCUSS] KIP-536: Propagate broker timestamp to Admin API

2019-11-13 Thread Jason Gustafson
Sorry, that should be "Hi Noa" On Wed, Nov 13, 2019 at 8:43 AM Jason Gustafson wrote: > Ni Noa, > > Thanks for the KIP. I agree with the concerns about Metadata bloat. In > fact, I have wanted a BrokerStatus API for a while now. Perhaps this is a > good excuse to int

Re: [DISCUSS] KIP-536: Propagate broker timestamp to Admin API

2019-11-13 Thread Jason Gustafson
Ni Noa, Thanks for the KIP. I agree with the concerns about Metadata bloat. In fact, I have wanted a BrokerStatus API for a while now. Perhaps this is a good excuse to introduce it. I was thinking something like this: BrokerStatusRequest => BrokerId BrokerStatusResponse => Listeners => [Listen

[jira] [Resolved] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

2019-11-08 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9133. Resolution: Fixed > LogCleaner thread dies with: currentLog cannot be empty on

Re: [VOTE] KIP-543: Expand ConfigCommand's non-ZK functionality

2019-11-07 Thread Jason Gustafson
+1 Looking forward to this. I love the quality-of-life changes. On Thu, Nov 7, 2019 at 7:00 PM Manikumar wrote: > +1 (binding), Thanks for the KIP. > > > > On Fri, Nov 8, 2019 at 8:14 AM Gwen Shapira wrote: > > > +1 (binding) > > > > Thank you. > > > > On Thu, Nov 7, 2019, 8:41 AM Brian Byrne

[jira] [Created] (KAFKA-9150) DescribeGroup uses member assignment as metadata

2019-11-06 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9150: -- Summary: DescribeGroup uses member assignment as metadata Key: KAFKA-9150 URL: https://issues.apache.org/jira/browse/KAFKA-9150 Project: Kafka Issue

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