[jira] [Created] (KAFKA-10596) Adding some state to TransactionMetadata which explicitly indicates that the transaction was timed out

HaiyuanZhao created KAFKA-10596: --- Summary: Adding some state to TransactionMetadata which explicitly indicates that the transaction was timed out Key: KAFKA-10596 URL:

[jira] [Resolved] (KAFKA-10584) IndexSearchType should use sealed trait instead of Enumeration

[ https://issues.apache.org/jira/browse/KAFKA-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-10584. Fix Version/s: 2.7.0 Resolution: Fixed > IndexSearchType should use sealed trait instead of

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #132

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #161

See Changes: [github] KAFKA-9393: DeleteRecords may cause extreme lock contention for large partition directories (#7929) -- [...truncated 3.42 MB...]

[jira] [Created] (KAFKA-10595) Explain idempotent producer in max.in.flight.requests.per.connection

Yeva Byzek created KAFKA-10595: -- Summary: Explain idempotent producer in max.in.flight.requests.per.connection Key: KAFKA-10595 URL: https://issues.apache.org/jira/browse/KAFKA-10595 Project: Kafka

Re: Can I get a review for a documentation update (KAFKA-10473)?

Hi, Would someone be able to review this pull request for me? This is a small documentation change. Thanks, -James > On Sep 24, 2020, at 11:53 PM, James Cheng wrote: > > Hi, > > Can I get a review from one of the commiters for this documentation update? > > I am adding docs for the

Re: [VOTE] KIP-630: Kafka Raft Snapshot

Thanks for the votes Jun, Jason, Ron, Lucas and Guozhang. Thanks for the feedback Ron and Jun. Agree with your comments Ron. I have updated those configurations to metadata.snapshot.min.changed_records.ratio and metadata.snapshot.min.new_records.size. I thought of using "clenable" to keep it

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #160

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #128

See

[jira] [Resolved] (KAFKA-9393) DeleteRecords may cause extreme lock contention for large partition directories

[ https://issues.apache.org/jira/browse/KAFKA-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-9393. Fix Version/s: 2.7.0 Assignee: Gardner Vickers Resolution: Fixed merged to trunk. >

[jira] [Resolved] (KAFKA-10509) Add metric to track throttle time due to hitting connection rate quota

[ https://issues.apache.org/jira/browse/KAFKA-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-10509. - Resolution: Fixed Resolved via [https://github.com/apache/kafka/pull/9317] merged on 9/28. >

[jira] [Resolved] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6078. Resolution: Fixed > Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster >

[jira] [Resolved] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8940. Resolution: Fixed > Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance >

[jira] [Resolved] (KAFKA-10140) Incremental config api excludes plugin config changes

[ https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-10140. - Resolution: Fixed > Incremental config api excludes plugin config changes >

[jira] [Resolved] (KAFKA-6824) Flaky Test DynamicBrokerReconfigurationTest#testAddRemoveSslListener

[ https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6824. Resolution: Fixed > Flaky Test DynamicBrokerReconfigurationTest#testAddRemoveSslListener >

[jira] [Resolved] (KAFKA-8257) Flaky Test DynamicConnectionQuotaTest#testDynamicListenerConnectionQuota

[ https://issues.apache.org/jira/browse/KAFKA-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8257. Resolution: Fixed > Flaky Test DynamicConnectionQuotaTest#testDynamicListenerConnectionQuota >

[jira] [Resolved] (KAFKA-8139) Flaky Test SaslSslAdminClientIntegrationTest#testMetadataRefresh

[ https://issues.apache.org/jira/browse/KAFKA-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8139. Resolution: Fixed > Flaky Test SaslSslAdminClientIntegrationTest#testMetadataRefresh >

[jira] [Resolved] (KAFKA-8092) Flaky Test GroupAuthorizerIntegrationTest#testSendOffsetsWithNoConsumerGroupDescribeAccess

[ https://issues.apache.org/jira/browse/KAFKA-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8092. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-8076) Flaky Test ProduceRequestTest#testSimpleProduceRequest

[ https://issues.apache.org/jira/browse/KAFKA-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8076. Resolution: Fixed > Flaky Test ProduceRequestTest#testSimpleProduceRequest >

[jira] [Resolved] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7647. Resolution: Fixed > Flaky test >

[jira] [Resolved] (KAFKA-8137) Flaky Test LegacyAdminClientTest#testOffsetsForTimesWhenOffsetNotFound

[ https://issues.apache.org/jira/browse/KAFKA-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8137. Resolution: Fixed > Flaky Test LegacyAdminClientTest#testOffsetsForTimesWhenOffsetNotFound >

[jira] [Resolved] (KAFKA-8084) Flaky Test DescribeConsumerGroupTest#testDescribeMembersOfExistingGroupWithNoMembers

[ https://issues.apache.org/jira/browse/KAFKA-8084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8084. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8108. Resolution: Fixed > Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer >

[jira] [Resolved] (KAFKA-8303) Flaky Test SaslSslAdminClientIntegrationTest#testLogStartOffsetCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8303. Resolution: Fixed > Flaky Test SaslSslAdminClientIntegrationTest#testLogStartOffsetCheckpoint >

[jira] [Resolved] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7988. Resolution: Fixed > Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize >

[jira] [Resolved] (KAFKA-8079) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest#shouldSurviveFastLeaderChange

[ https://issues.apache.org/jira/browse/KAFKA-8079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8079. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-8113) Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8113. Resolution: Fixed > Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch >

[jira] [Resolved] (KAFKA-8087) Flaky Test PlaintextConsumerTest#testConsumingWithNullGroupId

[ https://issues.apache.org/jira/browse/KAFKA-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8087. Resolution: Fixed > Flaky Test PlaintextConsumerTest#testConsumingWithNullGroupId >

[jira] [Resolved] (KAFKA-8077) Flaky Test AdminClientIntegrationTest#testConsumeAfterDeleteRecords

[ https://issues.apache.org/jira/browse/KAFKA-8077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8077. Resolution: Fixed > Flaky Test AdminClientIntegrationTest#testConsumeAfterDeleteRecords >

[jira] [Resolved] (KAFKA-8075) Flaky Test GroupAuthorizerIntegrationTest#testTransactionalProducerTopicAuthorizationExceptionInCommit

[ https://issues.apache.org/jira/browse/KAFKA-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8075. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-8138) Flaky Test PlaintextConsumerTest#testFetchRecordLargerThanFetchMaxBytes

[ https://issues.apache.org/jira/browse/KAFKA-8138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8138. Resolution: Fixed > Flaky Test PlaintextConsumerTest#testFetchRecordLargerThanFetchMaxBytes >

[jira] [Resolved] (KAFKA-8141) Flaky Test FetchRequestDownConversionConfigTest#testV1FetchWithDownConversionDisabled

[ https://issues.apache.org/jira/browse/KAFKA-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8141. Resolution: Fixed > Flaky Test >

Re: Request to get subscribed for Kafka developers mailing list

Subscribing is self-service: https://kafka.apache.org/contact -Matthias On 10/9/20 12:12 PM, Srinath Thota wrote: > Hi, > > I would like to get enrolled in the Kafka developers Mailing List. I am > Srinath Thota currently working as a consultant in India. > > Thank you, Let me know if any

[jira] [Created] (KAFKA-10594) Enhance Raft exception handling

Boyang Chen created KAFKA-10594: --- Summary: Enhance Raft exception handling Key: KAFKA-10594 URL: https://issues.apache.org/jira/browse/KAFKA-10594 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-8269) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8269. Resolution: Duplicate > Flaky Test >

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #131

See Changes: [github] MINOR: Implement ApiError#equals and hashCode (#9390) -- [...truncated 3.42 MB...] org.apache.kafka.streams.TestTopicsTest >

Request to get subscribed for Kafka developers mailing list

Hi, I would like to get enrolled in the Kafka developers Mailing List. I am Srinath Thota currently working as a consultant in India. Thank you, Let me know if any additional information needed. Thanks, Srinath Thota

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #159

See Changes: [github] MINOR: ACLs for secured cluster system tests (#9378) -- [...truncated 6.84 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #127

See Changes: [github] MINOR: ACLs for secured cluster system tests (#9378) -- [...truncated 6.78 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #130

See Changes: [github] MINOR: ACLs for secured cluster system tests (#9378) -- [...truncated 3.43 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

how to consumer dynamic listener topic

| | kolnick | | koln...@163.com | 签名由网易邮箱大师定制

Re: [VOTE] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Thanks Jason for the great thoughts, and we basically decided to shift the gear for a limited impersonation approach offline. The goal here is to simplify the handling logic by relying on the active controller to do the actual authorization for resources in the original client request. We are

[jira] [Created] (KAFKA-10593) Kafka Hazelcast Process down

Cihan YILDIZ created KAFKA-10593: Summary: Kafka Hazelcast Process down Key: KAFKA-10593 URL: https://issues.apache.org/jira/browse/KAFKA-10593 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-10592) system tests not running after python3 merge

Ron Dagostino created KAFKA-10592: - Summary: system tests not running after python3 merge Key: KAFKA-10592 URL: https://issues.apache.org/jira/browse/KAFKA-10592 Project: Kafka Issue Type:

Re: New release branch 2.7

Hi Gwen, I've looked it over, and the work involved is low-risk, so I'm fine with you cherry-picking the PRs into 2.7 Bill On Thu, Oct 8, 2020 at 8:00 PM Gwen Shapira wrote: > Hey Bill! > > Thank you for driving this release! > > We are only now starting to work on KIP-629, so we missed

Re: [DISCUSSION] python code style checks

Thanks Nikolay, Sounds good to me in principle. I think linters serve a useful purpose. When it comes to the specific configuration, maybe you can open a POC PR so we can see what the formatter will do. Thanks, John On Fri, Oct 9, 2020, at 05:25, Brandon Brown wrote: > I love that idea,

Re: KIP-675: Convert KTable to a KStream using the previous value

I see. It's great hidden functionality and all you have to do is define a good API and expose it. I think the easiest thing would be to expose a first operator, and then add more operators if they are claimed. I think it is hidden for not complicating the API. Thank you El vie., 9 oct. 2020 a

Re: [VOTE] KIP-676: Respect the logging hierarchy

+1. (Non-binding) Thanks, Dongjin On Fri, Oct 9, 2020 at 6:50 PM Tom Bentley wrote: > Hi all, > > KIP-676 is pretty trivial and the comments on the discussion thread seem to > be favourable, so I'd like to start a vote on it. > > >

Re: [DISCUSSION] python code style checks

I love that idea, black is a really great formatter (opinionated with minimal config). Brandon Brown > On Oct 9, 2020, at 5:55 AM, Nikolay Izhikov wrote: > > Hello! > > Kafka uses relatively strict code style for Java code. > Code style enforces during project build. > > But, for now, we

Re: [VOTE] KIP-653: Upgrade log4j to log4j2

+1 non-binding. Thanks for your efforts on this Dongjin. Tom On Wed, Oct 7, 2020 at 6:45 AM Dongjin Lee wrote: > As of present: > > - Binding: +2 (Gwen, John) > - Non-binding: +1 (David) > > Now we need one more binding +1. > > Thanks, > Dongjin > > On Wed, Oct 7, 2020 at 1:37 AM David Jacot

[DISCUSSION] python code style checks

Hello! Kafka uses relatively strict code style for Java code. Code style enforces during project build. But, for now, we doesn’t check python test code style. I’ve checked system tests code with the default pylint settings and got the following results - "Your code has been rated at 5.98/10» I

[VOTE] KIP-676: Respect the logging hierarchy

Hi all, KIP-676 is pretty trivial and the comments on the discussion thread seem to be favourable, so I'd like to start a vote on it. https://cwiki.apache.org/confluence/display/KAFKA/KIP-676%3A+Respect+logging+hierarchy

[jira] [Resolved] (KAFKA-10591) kafka_2.13-2.6.0 vulnerabilities

[ https://issues.apache.org/jira/browse/KAFKA-10591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongjin Lee resolved KAFKA-10591. - Resolution: Duplicate See: [KAFKA-9366|http://https://issues.apache.org/jira/browse/KAFKA-9366]

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #126

See Changes: [cshapi] MINOR update comments and docs to be gender-neutral -- [...truncated 6.79 MB...] org.apache.kafka.streams.TestTopicsTest >

[jira] [Created] (KAFKA-10591) kafka_2.13-2.6.0 vulnerabilities

Manvindar created KAFKA-10591: - Summary: kafka_2.13-2.6.0 vulnerabilities Key: KAFKA-10591 URL: https://issues.apache.org/jira/browse/KAFKA-10591 Project: Kafka Issue Type: Bug Affects