[jira] [Resolved] (KAFKA-10214) fix flaky zookeeper_tls_test.py

2020-07-01 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-10214. --- Fix Version/s: 2.6.0 Resolution: Fixed Issue resolved by pull request 8949

[DISCUSS] KIP-363

2020-07-01 Thread Tom Bentley
Hi all, Following a suggestion from Colin in the KIP-625 discussion thread, I'd like to start discussion on a much smaller KIP which proposes to make error codes and messages tagged fields in all RPCs.

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [mkumar] KAFKA-10214: Fix zookeeper_tls_test.py system test -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Resolved] (KAFKA-10153) Error Reporting in Connect Documentation

2020-07-01 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-10153. --- Reviewer: Randall Hauch Resolution: Fixed > Error Reporting in Connect Documentation

[GitHub] [kafka-site] Wavez opened a new pull request #273: Update introduction.html - grammar

2020-07-01 Thread GitBox
Wavez opened a new pull request #273: URL: https://github.com/apache/kafka-site/pull/273 fixed grammar This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Build failed in Jenkins: kafka-trunk-jdk14 #258

2020-07-01 Thread Apache Jenkins Server
See Changes: [mkumar] KAFKA-10214: Fix zookeeper_tls_test.py system test -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: Kafka Exactly-Once Semantics in .NET support

2020-07-01 Thread Saher Ahwal
Hi Boyang Thank you so much for the reply. I opened an issue on confluent dotnet on github and it was answered here: https://github.com/confluentinc/confluent-kafka-dotnet/issues/1342 I will re-paste it here for the benefit of others who might be interested: Matt's reply from Confluent: " We

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [mkumar] KAFKA-10214: Fix zookeeper_tls_test.py system test -- [...truncated 3.16 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

Re: [DISCUSS] KIP-632: Add DirectoryConfigProvider

2020-07-01 Thread Manikumar
Hi, Thanks for the KIP. KIP looks good to me and will be a useful addition. Thanks, Manikumar On Mon, Jun 29, 2020 at 4:05 PM Tom Bentley wrote: > Hi all, > > I would like to start discussion on a small KIP to make using the config > provider mechanism more ergonomic on Kubernetes: > > >

[GitHub] [kafka-site] guozhangwang merged pull request #273: Update introduction.html - grammar

2020-07-01 Thread GitBox
guozhangwang merged pull request #273: URL: https://github.com/apache/kafka-site/pull/273 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

NODE JS INTERACTION WITH KAFKA

2020-07-01 Thread Ankit Kumar
Hi, I have implemented Kakfa with node js using node module node-kafka. node version : 10.17 node-kafka : 5.0.0 I am using consumer groups and default producers. The issue that I am facing is that the consumers are not able to consume the messages randomly. Any help would be appreciated. Thank

[GitHub] [kafka-site] Wavez commented on pull request #273: Update introduction.html - grammar

2020-07-01 Thread GitBox
Wavez commented on pull request #273: URL: https://github.com/apache/kafka-site/pull/273#issuecomment-652596979 @guozhangwang https://github.com/apache/kafka/pull/8969 This is an automated message from the Apache Git

[GitHub] [kafka-site] guozhangwang commented on pull request #273: Update introduction.html - grammar

2020-07-01 Thread GitBox
guozhangwang commented on pull request #273: URL: https://github.com/apache/kafka-site/pull/273#issuecomment-652574973 @Wavez Could you also submit a fix in `https://github.com/apache/kafka` under `docs/introduction.html`?

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10153: Error Reporting in Connect Documentation (#8858) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: add retry to system test curl commands (#8961) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

2020-07-01 Thread Boyang Chen
Hey folks, I have also synced on the KIP-578 which was doing the partition limit, to make sure the partition limit error code would be properly propagated once it is done on top of KIP-590. Let me know if you have further questions or concerns. Boyang On Tue, Jun 23, 2020 at 5:08 PM Boyang Chen

Build failed in Jenkins: kafka-trunk-jdk14 #259

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10153: Error Reporting in Connect Documentation (#8858) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[GitHub] [kafka-site] Wavez commented on pull request #273: Update introduction.html - grammar

2020-07-01 Thread GitBox
Wavez commented on pull request #273: URL: https://github.com/apache/kafka-site/pull/273#issuecomment-652595057 > @Wavez Could you also submit a fix in `https://github.com/apache/kafka` under `docs/introduction.html`? Sure

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10153: Error Reporting in Connect Documentation (#8858) -- [...truncated 3.16 MB...]

[jira] [Resolved] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors

2020-07-01 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9018. -- Resolution: Fixed > Kafka Connect - throw clearer exceptions on serialisation errors >

Build failed in Jenkins: kafka-trunk-jdk14 #260

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: add retry to system test curl commands (#8961) -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: add retry to system test curl commands (#8961) -- [...truncated 3.16 MB...]

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

2020-07-01 Thread Jorge Esteban Quilcate Otoya
Quick update: KIP is updated with latest changes now. Will leave it open this week while working on the PR. Hope to open a new vote thread over the next few days if no additional feedback is provided. Cheers, Jorge. On Mon, Jun 29, 2020 at 11:30 AM Jorge Esteban Quilcate Otoya <

Feedback: Print schemaId using bin/kafka-dump-log.sh

2020-07-01 Thread Mohanraj Nagasamy
When I try to dump kafka logs for diagnosing or debugging a problem, It's handy to see if the kafka log message schemaId or not. If it has got, print the schemaId. I'm soliciting feedback as to whether it is worth making this change to kafka-core codebase. I'm new to the kafka-community -

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: Update introduction.html (#8969) -- [...truncated 3.19 MB...] org.apache.kafka.streams.scala.kstream.MaterializedTest > Create a

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-9018: Throw clearer exceptions on serialisation errors (#7496) [github] MINOR: Fix log entry in FetchSessionHandler to specify throttle --

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: Fix log entry in FetchSessionHandler to specify throttle -- [...truncated 3.16 MB...]

Build failed in Jenkins: kafka-trunk-jdk14 #262

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: Update introduction.html (#8969) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Resolved] (KAFKA-9678) Introduce bounded exponential backoff in clients

2020-07-01 Thread Sanjana Kaundinya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya resolved KAFKA-9678. -- Resolution: Duplicate > Introduce bounded exponential backoff in clients >

[jira] [Resolved] (KAFKA-9893) Configurable TCP connection timeout and improve the initial metadata fetch

2020-07-01 Thread Sanjana Kaundinya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya resolved KAFKA-9893. -- Resolution: Implemented > Configurable TCP connection timeout and improve the initial

[jira] [Reopened] (KAFKA-9678) Introduce bounded exponential backoff in clients

2020-07-01 Thread Sanjana Kaundinya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya reopened KAFKA-9678: -- > Introduce bounded exponential backoff in clients >

Build failed in Jenkins: kafka-trunk-jdk14 #261

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-9018: Throw clearer exceptions on serialisation errors (#7496) [github] MINOR: Fix log entry in FetchSessionHandler to specify throttle --

Kafka Streams: Dynamic Topic Routing & Nonexistent Topics

2020-07-01 Thread Rhys Anthony McCaig
Hi All, I have been recently working on a streams application that uses a TopicNameExtractor to dynamically route records based on the payload. This streams application is used by various other applications, and occasionally these other applications request for a record to be sent to a

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: Update introduction.html (#8969) -- [...truncated 3.16 MB...] org.apache.kafka.streams.internals.WindowStoreFacadeTest >

Re: Kafka Exactly-Once Semantics in .NET support

2020-07-01 Thread Boyang Chen
Thanks for the interest Saher. TBH, I don't know how the .NET confluent library works, but I would assume it is based on the https://github.com/edenhill/librdkafka. Maybe propose an issue there as well to attract some expertes. Boyang On Tue, Jun 30, 2020 at 3:22 PM Saher Ahwal wrote: > Hi > >

Re: Permission to create a KIP

2020-07-01 Thread Manikumar
Hi, Thanks for your interest. I have given you wiki edit permissions. Thanks, On Wed, Jul 1, 2020 at 2:50 AM Jeremy Custenborder wrote: > Hello All, > > Could someone grant permissions to create a KIP to the user jcustenborder? > > Thanks! >

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

2020-07-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-9018: Throw clearer exceptions on serialisation errors (#7496) -- [...truncated 3.17 MB...]

Kafka Streams: Dynamic Topic Routing & Nonexistent Topics

2020-07-01 Thread Rhys Anthony McCaig
Hi All, I have been recently working on a streams application that uses a TopicNameExtractor to dynamically route records based on the payload. This streams application is used by various other applications, and occasionally these other applications request for a record to be sent to a

[jira] [Created] (KAFKA-10224) The license term about jersey is not correct

2020-07-01 Thread jaredli2020 (Jira)
jaredli2020 created KAFKA-10224: --- Summary: The license term about jersey is not correct Key: KAFKA-10224 URL: https://issues.apache.org/jira/browse/KAFKA-10224 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-632: Add DirectoryConfigProvider

2020-07-01 Thread David Jacot
Hi Tom, I think that it is a useful addition. The KIP looks good to me. Thanks, David Le mer. 1 juil. 2020 à 18:58, Manikumar a écrit : > Hi, > > Thanks for the KIP. > KIP looks good to me and will be a useful addition. > > Thanks, > Manikumar > > On Mon, Jun 29, 2020 at 4:05 PM Tom Bentley

[jira] [Created] (KAFKA-10222) Incorrect methods show up in 0.10 Kafka Streams docs

2020-07-01 Thread huxihx (Jira)
huxihx created KAFKA-10222: -- Summary: Incorrect methods show up in 0.10 Kafka Streams docs Key: KAFKA-10222 URL: https://issues.apache.org/jira/browse/KAFKA-10222 Project: Kafka Issue Type: Bug

Re: Permission to create a KIP

2020-07-01 Thread Manikumar
Hi, Thanks for your interest. I have given you wiki edit permissions. Thanks, On Wed, Jul 1, 2020 at 3:25 AM Mohamed Chebbi wrote: > Hi > > could somone grant permission to create a KIP to user mhmdchebbi? > > > Best Reguards > >

[jira] [Created] (KAFKA-10223) ReplicaNotAvailableException must be retriable to handle reassignments

2020-07-01 Thread Rajini Sivaram (Jira)
Rajini Sivaram created KAFKA-10223: -- Summary: ReplicaNotAvailableException must be retriable to handle reassignments Key: KAFKA-10223 URL: https://issues.apache.org/jira/browse/KAFKA-10223 Project:

[GitHub] [kafka-site] huxihx opened a new pull request #272: KAFKA-10222:Incorrect methods show up in 0.10 Kafka Streams docs

2020-07-01 Thread GitBox
huxihx opened a new pull request #272: URL: https://github.com/apache/kafka-site/pull/272 https://issues.apache.org/jira/browse/KAFKA-10222 Non-existent methods show up in the doc: _builder.from("my-input-topic").mapValue(value ->

[GitHub] [kafka-site] huxihx commented on pull request #272: KAFKA-10222:Incorrect methods show up in 0.10 Kafka Streams docs

2020-07-01 Thread GitBox
huxihx commented on pull request #272: URL: https://github.com/apache/kafka-site/pull/272#issuecomment-652295642 @ijuma Please review this patch. Thanks. This is an automated message from the Apache Git Service. To respond