Re: [VOTE] KIP-527: Add VoidSerde to Serdes

Hi Nikolay, Thank you for the KIP! +1 (non-binding) Best, Bruno On Tue, Oct 1, 2019 at 5:57 PM Nikolay Izhikov wrote: > > Hello. > > I would like to start vote for KIP-527: Add VoidSerde to Serdes > > KIP - > https://cwiki.apache.org/confluence/display/KAFKA/KIP-527%3A+Add+VoidSerde+to+Serdes

Build failed in Jenkins: kafka-trunk-jdk8 #3937

See Changes: [mumrah] KAFKA-8896: Check group state before completing delayed heartbeat [github] KAFKA-8807: Flaky GlobalStreamThread test (#7418) -- [...truncated 7.44

Jenkins build is back to normal : kafka-trunk-jdk11 #847

See

Build failed in Jenkins: kafka-2.3-jdk8 #114

See Changes: -- [...truncated 2.94 MB...] kafka.security.auth.SimpleAclAuthorizerTest > testAddAclsOnLiteralResource PASSED kafka.security.auth.SimpleAclAuthorizerTest > testAuthorizeTh

Re: [VOTE] KIP-416: Notify SourceTask of ACK'd offsets, metadata

Hey y'all, resurrecting an old KIP for the benefit of KIP-382, which depends on an additional parameter in SourceTask.commitRecord(). I've updated KIP-416 according to consensus reached in PR-6295. Let's finish the vote so we can formally approve this minor KIP, please! Ryanne On Mon, Jan 21, 201

[jira] [Resolved] (KAFKA-8595) Support SerDe of Decimals in JSON that are not HEX encoded

[ https://issues.apache.org/jira/browse/KAFKA-8595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8595. -- Fix Version/s: 2.4.0 Reviewer: Randall Hauch Resolution: Fixed KIP-481 was appr

Build failed in Jenkins: kafka-trunk-jdk8 #3936

See Changes: [github] MINOR: Mark RocksDBStoreTest as integration test (#7412) -- [...truncated 4.99 MB...] kafka.api.SslProducerSendTest > testFlush PASSED kafka.api.Ss

Build failed in Jenkins: kafka-trunk-jdk11 #846

See Changes: [github] MINOR: Mark RocksDBStoreTest as integration test (#7412) [mumrah] KAFKA-8896: Check group state before completing delayed heartbeat -- [...truncate

Re: [DISCUSS] KIP-416: Notify SourceTask of ACK'd offsets, metadata

I favour this approach too. Andrew Schofield On 01/10/2019, 09:15, "Ryanne Dolan" wrote: Thanks Randall, that works for me. Ryanne On Tue, Oct 1, 2019 at 9:09 AM Randall Hauch wrote: > Apologies for the late entry -- I entirely missed this KIP and discussion.

Build failed in Jenkins: kafka-2.3-jdk8 #113

See Changes: [mumrah] KAFKA-8896: Check group state before completing delayed heartbeat -- [...truncated 2.94 MB...] kafka.log.ProducerStateManagerTest > testAppendTxnMarker

[jira] [Created] (KAFKA-8967) Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

Stanislav Kozlovski created KAFKA-8967: -- Summary: Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig Key: KAFKA-8967 URL: https://issues.apache.org/jira/browse/KA

[jira] [Created] (KAFKA-8966) Stream state does not transition to RUNNING on client, broker consumer group shows RUNNING

Raman Gupta created KAFKA-8966: -- Summary: Stream state does not transition to RUNNING on client, broker consumer group shows RUNNING Key: KAFKA-8966 URL: https://issues.apache.org/jira/browse/KAFKA-8966

ApacheCon North America 2020, project participation

Hi, folks, (Note: You're receiving this email because you're on the dev@ list for one or more Apache Software Foundation projects.) For ApacheCon North America 2019, we asked projects to participate in the creation of project/topic specific tracks. This was very successful, with about 15 projects

Re: [DISCUSS] Notify SourceTask of ACK'd offsets, metadata

Huh. Not sure how that happened. Will update the KIP, thanks. On Tue, Oct 1, 2019 at 9:12 AM Randall Hauch wrote: > There seems to be two discussion threads for this KIP, and I replied to the > other thread that includes the KIP number. Shall I repeat it here? > > Also, the link to the discussi

Re: [DISCUSS] KIP-416: Notify SourceTask of ACK'd offsets, metadata

Thanks Randall, that works for me. Ryanne On Tue, Oct 1, 2019 at 9:09 AM Randall Hauch wrote: > Apologies for the late entry -- I entirely missed this KIP and discussion. > :-( > > Thanks for creating the KIP and proposing this change. I do think it's > useful for source connector tasks to get

Re: [DISCUSS] Notify SourceTask of ACK'd offsets, metadata

There seems to be two discussion threads for this KIP, and I replied to the other thread that includes the KIP number. Shall I repeat it here? Also, the link to the discussion thread on https://cwiki.apache.org/confluence/display/KAFKA/KIP-416%3A+Notify+SourceTask+of+ACK%27d+offsets%2C+metadata sh

Re: [DISCUSS] KIP-416: Notify SourceTask of ACK'd offsets, metadata

Apologies for the late entry -- I entirely missed this KIP and discussion. :-( Thanks for creating the KIP and proposing this change. I do think it's useful for source connector tasks to get more information about the acknowledgement after the record was written. However, given the KIPs suggestio

[VOTE] KIP-527: Add VoidSerde to Serdes

Hello. I would like to start vote for KIP-527: Add VoidSerde to Serdes KIP - https://cwiki.apache.org/confluence/display/KAFKA/KIP-527%3A+Add+VoidSerde+to+Serdes Discussion thread - https://lists.apache.org/thread.html/e6f95799898cc5d6e7d44dfd3fc2206117feb384a0a229a1c781ecd4@%3Cdev.kafka.apache

Re: [Discuss] - KIP-532 - Add KStream#toTable to the Streams DSL

Thank you all for the feedback, I will keep this thread open for discussion for a couple of more days and then start with the voting process. Best regards, Aishwarya On Fri, Sep 27, 2019, 12:37 PM John Roesler wrote: > Looks good to me! I have no further comments. > > Thanks again for the KIP,

Re: Granting permissions for Create KIP

Rabi, You're all set now. Thanks for the interest in Apache Kafka. -Bill On Tue, Oct 1, 2019 at 6:49 AM RABI K.C. wrote: > Hello, > > I am new to kafka and have to create KIP for KAFKA-8953 and was going > through > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposa

Granting permissions for Create KIP

Hello, I am new to kafka and have to create KIP for KAFKA-8953 and was going through https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals to create KIP. However, it seems I don't have permission to create KIP. *Wiki id: rabikumar.kc* Please do let me know if anything els

[jira] [Created] (KAFKA-8965) record-lateness-[avg|max] is always NaN

Junze Bao created KAFKA-8965: Summary: record-lateness-[avg|max] is always NaN Key: KAFKA-8965 URL: https://issues.apache.org/jira/browse/KAFKA-8965 Project: Kafka Issue Type: Bug Affects Ver

Build failed in Jenkins: kafka-trunk-jdk11 #845

See Changes: [wangguoz] MINOR: Adjust logic of conditions to set number of partitions in step [wangguoz] KAFKA-8609: Add rebalance-latency-total (#7401) [wangguoz] KAFKA-8927: Deprecate PartitionGrouper interfa