Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #8

See Changes: [github] HOTFIX: use Exit.exit instead of System.exit (#9198) -- [...truncated 6.30 MB...] org.apache.kafka.streams.TopologyTestDriverTest > should

[jira] [Resolved] (KAFKA-9708) Connector does not prefer to use packaged classes during configuration

[ https://issues.apache.org/jira/browse/KAFKA-9708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9708. --- Resolution: Fixed > Connector does not prefer to use packaged classes during

[GitHub] [kafka-site] guozhangwang commented on pull request #293: MINOR: fix for quickstart in docs

guozhangwang commented on pull request #293: URL: https://github.com/apache/kafka-site/pull/293#issuecomment-675832265 @scott-confluent After merged the PR the new link seems still not working? This is an automated message fr

[GitHub] [kafka-site] guozhangwang merged pull request #293: MINOR: fix for quickstart in docs

guozhangwang merged pull request #293: URL: https://github.com/apache/kafka-site/pull/293 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: KIP-658 Deprecate all setters of Headers

> If you create a new `ProducerRecord` you would not pass in a `Headers` > object but a `Iterable`? > > And for `ConsumerRecord` you just get a `Headers` object back and don't > need to worry about the concrete implementation? You are right. I'd give a bad case :( For another reason, could we av

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Hi, Looks like there are enough votes to accept the KIP: 3 binding and 1 non-binding. The pull request is waiting for the merge: https://github.com/apache/kafka/pull/8955 Thanks, everybody! -Yuriy On Wed, Aug 19, 2020 at 4:51 AM Bill Bejeck wrote: > Thanks for the KIP Yuriy, this will be a gr

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

See Changes: [github] KAFKA-9705 part 1: add KIP-590 request header fields (#9144) -- [...truncated 6.45 MB...] org.apache.kafka.streams.TopologyTestDriverTe

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

See

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

See Changes: [github] KAFKA-9705 part 1: add KIP-590 request header fields (#9144) -- [...truncated 3.22 MB...] org.apache.kafka.streams.test.OutputVerifierTe

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Thanks Matthias, Sounds good. I'm on board with no public API change and just recovering instead of crashing. Also, to be clear, I wouldn't drag KTables into it; I was just trying to wrap my head around the congruity of our choice for GlobalKTable with respect to KTable. I agree that whatever we

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Thanks for the KIP Yuriy, this will be a great addition. +1 (binding) -Bill On Tue, Aug 18, 2020 at 5:47 PM Matthias J. Sax wrote: > Thanks for the KIP Yuriy! > > +1 (binding) > > > -Matthias > > On 8/13/20 9:49 PM, John Roesler wrote: > > Hi Yuriy, > > > > What a coincidence! I was just about

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Thanks for the KIP Yuriy! +1 (binding) -Matthias On 8/13/20 9:49 PM, John Roesler wrote: > Hi Yuriy, > > What a coincidence! I was just about to bump this thread myself. It would be > really nice to get some more votes to push this over the line. > > Thanks for your patience! > > -John >

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Thanks for the discussion. I agree that this KIP is justified in any case -- even if we don't change public API, as the change in behavior is significant. A better documentation for cleanup policy is always good (even if I am not aware of any concrete complaints atm that users were not aware of t

Re: Permission to modify/comment on the Kafka confluence wiki pages

Sanjay, I granted you wiki access. However, I am wondering what parts for the page you pointed out need an update? I recently followed the instructions and it worked for me. -Matthias On 8/18/20 12:02 AM, Sanjay Y R wrote: > Hello, > > I am Sanjay. I am looking to contribute to Kafka Open Sourc

Re: KIP-658 Deprecate all setters of Headers

Thanks for the KIP. However, I am not sure for what use-case you would need to implement the `Headers` interface? If you create a new `ProducerRecord` you would not pass in a `Headers` object but a `Iterable`? And for `ConsumerRecord` you just get a `Headers` object back and don't need to worry a

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

Adding the user mailing list -- I think we should accepts votes on both lists for this special case, as it's not a technical decision. @Boyang: as mentioned by Bruno, can we maybe add black/white options for both proposals, too? I also agree that Design B is not ideal with regard to the Kafka log

[jira] [Created] (KAFKA-10419) KAFKA BROKER Shuts down when a topic is deleted manually from command line on Windows 1) operating System.

Ajay Kapoor created KAFKA-10419: --- Summary: KAFKA BROKER Shuts down when a topic is deleted manually from command line on Windows 1) operating System. Key: KAFKA-10419 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Created] (KAFKA-10418) Unclear deprecation of altering topic configs via kafka-topics with --bootstrap-server

Ron Dagostino created KAFKA-10418: - Summary: Unclear deprecation of altering topic configs via kafka-topics with --bootstrap-server Key: KAFKA-10418 URL: https://issues.apache.org/jira/browse/KAFKA-10418

Re: Permission to create a KIP

Done, thanks for the interest in Kafka! On Tue, Aug 18, 2020 at 10:20 AM Neemias Junior wrote: > Hello, could you please give me permission to create a Kafka Improvement > Proposal? My ID is neemiasjnr. If you want I can explain what I'm going to > propose beforehand. Thank you! > > Best regards

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

Hi, Thanks for the KIP, really like the idea. I am +1(non-binding) on A mainly because I felt like you have to tilt your head to realize the otter's head in B.  Regards,Navinder On Tuesday, 18 August, 2020, 11:44:20 pm IST, Guozhang Wang wrote: I'm leaning towards design B primarily

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

I'm leaning towards design B primarily because it reminds me of the Firefox logo which I like a lot. But I also share Adam's concern that it should better not obscure the Kafka logo --- so if we can tweak a bit to fix it my vote goes to B, otherwise A :) Guozhang On Tue, Aug 18, 2020 at 9:48 AM

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Kowshik, Thanks for looking into the KIP and sending your comments. 5001. Under the section "Follower fetch protocol in detail", the next-local-offset is the offset upto which the segments are copied to remote storage. Instead, would last-tiered-offset be a better name than next-local-offset

Permission to create a KIP

Hello, could you please give me permission to create a Kafka Improvement Proposal? My ID is neemiasjnr. If you want I can explain what I'm going to propose beforehand. Thank you! Best regards, Neemias.

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

Hi there, Just a small nudge on this as this happened once more at Yelp 😄 Was there any progress on this? If not, is there anything we can do to help? Thank you, Flavien On 2020/02/13 11:34:14, Satish Duggana wrote: > Hi Lucas,> > Thanks for looking into the KIP and providing your comments.>

Re: [VOTE] KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override

Hello everyone, Please, if you are interested in this KIP and PR, don't forget to vote. Thank you, Daniel Dániel Urbán ezt írta (időpont: 2020. aug. 13., Cs, 14:00): > Hi David, > > Thank you for the suggestion. KIP-635 was referencing the --broker-list > issue, but based on your suggestion, I

[jira] [Resolved] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-10395. - Fix Version/s: 2.7.0 Resolution: Fixed > TopologyTestDriver does not work

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

Thanks for the KIP! I am +1 (non-binding) for A. I would also like to hear opinions whether the logo should be colorized or just black and white. Best, Bruno On 15.08.20 16:05, Adam Bellemare wrote: I prefer Design B, but given that I missed the discussion thread, I think it would be bette

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

See Changes: [github] KAFKA-10395: relax output topic check in TTD to work with dynamic routing (#9174) -- [...truncated 1.82 MB...] kafka.api.SaslScramSslEnd

Kafka log cleanup

Hi , Iam using kafka_2.12-2.5.0 with defalut log cleaup default is 7 days. and trying maintain kafka log cleanup and compact within 24hours.Iam getting errors while reaching 24hours period.Can you please send me wt are all configurations need to maintain at server.properties, produce.properties

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

See Changes: [github] KAFKA-10395: relax output topic check in TTD to work with dynamic routing (#9174) -- [...truncated 2.52 MB...] org.apache.kafka.streams

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

See Changes: [github] KAFKA-10395: relax output topic check in TTD to work with dynamic routing (#9174) -- [...truncated 1.62 MB...] kafka.security.auth.Res

Permission to modify/comment on the Kafka confluence wiki pages

Hello, I am Sanjay. I am looking to contribute to Kafka Open Source. I was going through the Kafka wiki pages and saw that some of them are outdated. I would like to fix or comment on the pages. For example, https://cwiki.apache.org/confluence/display/KAFKA/Setup+Kafka+Website+on+Local+Apache+Serv

Re: [jira] [Created] (KAFKA-10415) Provide an officially supported Node.js client

FWIW, Wikimedia uses node-rdkafka from Blizzard, and is pretty happy with it. I think Blizzard is trying to find external supports and maintainers though, so the project may not be well supported there for much longer. On Tue, Aug 18, 2020 at 10:32 A

[jira] [Created] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

Wardha Perinkada Kattu created KAFKA-10417: -- Summary: suppress() with cogroup() throws ClassCastException Key: KAFKA-10417 URL: https://issues.apache.org/jira/browse/KAFKA-10417 Project: Kafka

[jira] [Created] (KAFKA-10416) Provide an officially supported Deno client

Matthew T. Adams created KAFKA-10416: Summary: Provide an officially supported Deno client Key: KAFKA-10416 URL: https://issues.apache.org/jira/browse/KAFKA-10416 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-10415) Provide an officially supported Node.js client

Matthew T. Adams created KAFKA-10415: Summary: Provide an officially supported Node.js client Key: KAFKA-10415 URL: https://issues.apache.org/jira/browse/KAFKA-10415 Project: Kafka Issue

[jira] [Created] (KAFKA-10414) Upgrade api-util dependency - CVE-2018-1337

Daniel Urban created KAFKA-10414: Summary: Upgrade api-util dependency - CVE-2018-1337 Key: KAFKA-10414 URL: https://issues.apache.org/jira/browse/KAFKA-10414 Project: Kafka Issue Type: Bug

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

+1 (binding) for design A. Thanks, Bill On Mon, Aug 17, 2020 at 5:06 PM Sven Erik Knop wrote: > Please use Design A > > On 2020/08/17 18:18:12, Abraham Leal wrote: > > I'd like to cast a non-binding vote to Design A.> > > Love the otter.> > > > > On 2020/08/15 14:05:10, Adam Bellemare wrote:>

[jira] [Created] (KAFKA-10413) rebalancing leads to unevenly balanced connectors

yazgoo created KAFKA-10413: -- Summary: rebalancing leads to unevenly balanced connectors Key: KAFKA-10413 URL: https://issues.apache.org/jira/browse/KAFKA-10413 Project: Kafka Issue Type: Bug

KIP-658 Deprecate all setters of Headers

Hi everyone, I would like to start a discussion on KIP-658: https://cwiki.apache.org/confluence/x/-DJ4CQ KIP-658 plans to deprecate all setters of Headers and provide default implementation. The benefit of this KIP are shown below. 1. Users don't need to implement those setters which are not u

[jira] [Created] (KAFKA-10412) Deprecate all setters of Headers

Chia-Ping Tsai created KAFKA-10412: -- Summary: Deprecate all setters of Headers Key: KAFKA-10412 URL: https://issues.apache.org/jira/browse/KAFKA-10412 Project: Kafka Issue Type: Improvement

[GitHub] [kafka-site] SanjayYr opened a new pull request #297: MINOR: fix for example implementation of how to add a new header to the record

SanjayYr opened a new pull request #297: URL: https://github.com/apache/kafka-site/pull/297 Fixed method invocation and arguments. This is an automated message from the Apache Git Service. To respond to the message, please lo

Build failed in Jenkins: Kafka » kafka-2.1-jdk8 #4

See Changes: [manikumar.reddy] MINOR: Use new version of ducktape -- [...truncated 2.82 MB...] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest

[GitHub] [kafka-site] SanjayYr opened a new pull request #296: MINOR: fix for extra line break in streams processor API documentation

SanjayYr opened a new pull request #296: URL: https://github.com/apache/kafka-site/pull/296 Removed the extra "/p" tag. This is an automated message from the Apache Git Service. To respond to the message, please log on to Git