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

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695306#comment-16695306 ] Jason Gustafson commented on KAFKA-7610: It turns out the disconnect option is a

[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] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692316#comment-16692316 ] Jason Gustafson commented on KAFKA-7531: [~spuzon] Thanks for the additional info

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

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692108#comment-16692108 ] Jason Gustafson commented on KAFKA-7610: [~guozhang] Here is a quick sketch of th

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

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692108#comment-16692108 ] Jason Gustafson edited comment on KAFKA-7610 at 11/19/18 6:49 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16689866#comment-16689866 ] Jason Gustafson edited comment on KAFKA-7610 at 11/16/18 6:55 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16689866#comment-16689866 ] Jason Gustafson commented on KAFKA-7610: For some background, the case we observe

[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] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685884#comment-16685884 ] Jason Gustafson commented on KAFKA-7610: [~bchen225242] Hmm.. Good question. Perh

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

[ https://issues.apache.org/jira/browse/KAFKA-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7601: --- Description: During an upgrade of the message format, there is a short time during which the

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

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685591#comment-16685591 ] Jason Gustafson edited comment on KAFKA-7610 at 11/13/18 6:47 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685591#comment-16685591 ] Jason Gustafson commented on KAFKA-7610: [~bchen225242] Yeah, it's a good point t

[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] [Commented] (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:comment-tabpanel&focusedCommentId=16681948#comment-16681948 ] Jason Gustafson commented on KAFKA-7549: Sorry for the late response. As I unders

[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] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677148#comment-16677148 ] Jason Gustafson commented on KAFKA-7531: [~spuzon] Thanks for the extra info. Yea

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

[ https://issues.apache.org/jira/browse/KAFKA-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7601: --- Description: During an upgrade of the message format, there is a short time during which the

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

[ https://issues.apache.org/jira/browse/KAFKA-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7601: --- Description: During an upgrade of the message format, there is a short time during which the

[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] [Comment Edited] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672410#comment-16672410 ] Jason Gustafson edited comment on KAFKA-7531 at 11/2/18 12:43 AM: -

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672410#comment-16672410 ] Jason Gustafson commented on KAFKA-7531: [~spuzon] Can you post the git commit id

[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] [Comment Edited] (KAFKA-7553) Jenkins PR tests hung

[ https://issues.apache.org/jira/browse/KAFKA-7553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670732#comment-16670732 ] Jason Gustafson edited comment on KAFKA-7553 at 10/31/18 9:11 PM: -

[jira] [Comment Edited] (KAFKA-7553) Jenkins PR tests hung

[ https://issues.apache.org/jira/browse/KAFKA-7553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670732#comment-16670732 ] Jason Gustafson edited comment on KAFKA-7553 at 10/31/18 9:11 PM: -

[jira] [Commented] (KAFKA-7553) Jenkins PR tests hung

[ https://issues.apache.org/jira/browse/KAFKA-7553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670732#comment-16670732 ] Jason Gustafson commented on KAFKA-7553: I submitted a patch to fix what I suspec

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

[ https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670312#comment-16670312 ] Jason Gustafson commented on KAFKA-6774: [~vahid] Do you have time to work on thi

[jira] [Commented] (KAFKA-7553) Jenkins PR tests hung

[ https://issues.apache.org/jira/browse/KAFKA-7553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16669285#comment-16669285 ] Jason Gustafson commented on KAFKA-7553: I investigated a few additional hanging

[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] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16669120#comment-16669120 ] Jason Gustafson commented on KAFKA-7481: I am also in favor of option 1 for the t

[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] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16657718#comment-16657718 ] Jason Gustafson commented on KAFKA-7481: [~lindong] [~ijuma] For consideration, I

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

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16657064#comment-16657064 ] Jason Gustafson commented on KAFKA-7481: [~ijuma] I'm not sure if it was the last

[jira] [Commented] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655934#comment-16655934 ] Jason Gustafson commented on KAFKA-7519: Good find and thanks for the investigati

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

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655701#comment-16655701 ] Jason Gustafson commented on KAFKA-7481: [~ijuma] [~lindong] Thanks for the respo

[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] [Updated] (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 updated KAFKA-7415: --- Fix Version/s: 1.1.2 > OffsetsForLeaderEpoch may incorrectly respond with undefined epoch cau

[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] [Updated] (KAFKA-7487) DumpLogSegments reports mismatches for indexed offsets which are not at the start of a record batch

[ https://issues.apache.org/jira/browse/KAFKA-7487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7487: --- Labels: newbie (was: ) > DumpLogSegments reports mismatches for indexed offsets which are no

[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] [Assigned] (KAFKA-7485) Flaky test `DyanamicBrokerReconfigurationTest.testTrustStoreAlter`

[ https://issues.apache.org/jira/browse/KAFKA-7485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7485: -- Assignee: Rajini Sivaram (was: Jason Gustafson) > Flaky test `DyanamicBrokerReconfigu

[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] [Commented] (KAFKA-7485) Flaky test `DyanamicBrokerReconfigurationTest.testTrustStoreAlter`

[ https://issues.apache.org/jira/browse/KAFKA-7485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16640194#comment-16640194 ] Jason Gustafson commented on KAFKA-7485: Note the leaking consumer issue is fixed

[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] [Commented] (KAFKA-7408) Truncate to LSO on unclean leader election

[ https://issues.apache.org/jira/browse/KAFKA-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16634476#comment-16634476 ] Jason Gustafson commented on KAFKA-7408: [~junrao] Good question. When we truncat

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

[ https://issues.apache.org/jira/browse/KAFKA-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7408: -- Assignee: (was: Jason Gustafson) > Truncate to LSO on unclean leader election > --

[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] [Commented] (KAFKA-7405) Support for graceful handling of corrupted records in Kafka consumer

[ https://issues.apache.org/jira/browse/KAFKA-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16631122#comment-16631122 ] Jason Gustafson commented on KAFKA-7405: Seems reasonable to me. This was brought

[jira] [Updated] (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 updated KAFKA-7414: --- Fix Version/s: 2.0.1 1.1.2 > Do not fail broker on out of range offsets in

[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] [Commented] (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:comment-tabpanel&focusedCommentId=16626228#comment-16626228 ] Jason Gustafson commented on KAFKA-7403: [~vahid] I was looking at this as part o

[jira] [Updated] (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 updated KAFKA-7403: --- Priority: Blocker (was: Major) > Offset commit failure after upgrading brokers past KIP-211/

[jira] [Updated] (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 updated KAFKA-7403: --- Affects Version/s: (was: 2.1.0) > Offset commit failure after upgrading brokers past KIP-

[jira] [Updated] (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 updated KAFKA-7403: --- Fix Version/s: 2.1.0 > Offset commit failure after upgrading brokers past KIP-211/KAFKA-4682

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

[ https://issues.apache.org/jira/browse/KAFKA-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7437: -- Assignee: Jason Gustafson > Store leader epoch in offset commit metadata > ---

[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] [Comment Edited] (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:comment-tabpanel&focusedCommentId=16618060#comment-16618060 ] Jason Gustafson edited comment on KAFKA-7150 at 9/21/18 12:34 AM: -

[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] [Assigned] (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 reassigned KAFKA-7415: -- Assignee: Jason Gustafson > OffsetsForLeaderEpoch may incorrectly respond with undefin

[jira] [Updated] (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 updated KAFKA-7395: --- Description: This patch implements the broker-side changes to support fencing improvements fr

[jira] [Updated] (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 updated KAFKA-7395: --- Summary: Add fencing to replication protocol (KIP-320) (was: Add fencing to OffsetsForLeader

[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] [Commented] (KAFKA-7403) Offset commit failure after broker upgrade to 2.0

[ https://issues.apache.org/jira/browse/KAFKA-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611393#comment-16611393 ] Jason Gustafson commented on KAFKA-7403: [~jonlee2] Thanks for the report. Would

[jira] [Updated] (KAFKA-7403) Offset commit failure after broker upgrade to 2.0

[ https://issues.apache.org/jira/browse/KAFKA-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7403: --- Affects Version/s: (was: 2.0.0) > Offset commit failure after broker upgrade to 2.0 > ---

[jira] [Updated] (KAFKA-7403) Offset commit failure after broker upgrade to 2.0

[ https://issues.apache.org/jira/browse/KAFKA-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7403: --- Affects Version/s: 2.0.0 > Offset commit failure after broker upgrade to 2.0 > --

[jira] [Assigned] (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 reassigned KAFKA-7044: -- Assignee: Anna Povzner (was: Vahid Hashemian) > kafka-consumer-groups.sh NullPointerE

[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] [Commented] (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:comment-tabpanel&focusedCommentId=16604639#comment-16604639 ] Jason Gustafson commented on KAFKA-7044: Thanks [~ejpearson] for the investigatio

[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] [Updated] (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 updated KAFKA-7164: --- Fix Version/s: 1.1.2 > Follower should truncate after every leader epoch change > ---

[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] [Updated] (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 updated KAFKA-7347: --- Description: We should return NOT_LEADER_FOR_PARTITION from OffsetsForLeaderEpoch requests to

[jira] [Updated] (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 updated KAFKA-7347: --- Summary: Wrong error code returned for OffsetsForLeaderEpoch from non-replica (was: Wrong er

[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] [Commented] (KAFKA-7335) Store clusterId locally to ensure broker joins the right cluster

[ https://issues.apache.org/jira/browse/KAFKA-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591871#comment-16591871 ] Jason Gustafson commented on KAFKA-7335: [~badai] That is one possibility. I was

[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] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588173#comment-16588173 ] Jason Gustafson commented on KAFKA-7190: [~lambdaliu] Yeah, I think maintaining t

<    8   9   10   11   12   13   14   15   16   17   >