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

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-jdk8 #4687

See Changes: [github] MINOR: Update introduction.html (#8969) -- [...truncated 3.16 MB...] org.apache.kafka.streams.internals.WindowStoreFacadeTest >

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

See Changes: [github] MINOR: Update introduction.html (#8969) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Kafka Streams: Dynamic Topic Routing & Nonexistent Topics

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

Kafka Streams: Dynamic Topic Routing & Nonexistent Topics

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

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

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-jdk8 #4686

See Changes: [github] MINOR: Fix log entry in FetchSessionHandler to specify throttle -- [...truncated 3.16 MB...]

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

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-jdk11 #1612

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

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

[ 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] [Reopened] (KAFKA-9678) Introduce bounded exponential backoff in clients

[ 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 >

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

[ 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

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

See Changes: [github] KAFKA-9018: Throw clearer exceptions on serialisation errors (#7496) -- [...truncated 3.17 MB...]

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

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 <

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

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 #260

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-jdk11 #1611

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

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

See Changes: [github] MINOR: add retry to system test curl commands (#8961) -- [...truncated 3.16 MB...]

Re: [DISCUSS] KIP-632: Add DirectoryConfigProvider

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-10224) The license term about jersey is not correct

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

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

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] Wavez commented on pull request #273: Update introduction.html - grammar

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

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

[ 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 >

NODE JS INTERACTION WITH KAFKA

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] guozhangwang merged pull request #273: Update introduction.html - grammar

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

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

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-jdk8 #4683

See Changes: [github] KAFKA-10153: Error Reporting in Connect Documentation (#8858) -- [...truncated 3.16 MB...]

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

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 #1610

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

Re: Kafka Exactly-Once Semantics in .NET support

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

Re: [DISCUSS] KIP-632: Add DirectoryConfigProvider

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: > > >

[DISCUSS] KIP-363

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.

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

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

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

[ 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

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

See Changes: [mkumar] KAFKA-10214: Fix zookeeper_tls_test.py system test -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

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

See Changes: [mkumar] KAFKA-10214: Fix zookeeper_tls_test.py system test -- [...truncated 3.16 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

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

See Changes: [mkumar] KAFKA-10214: Fix zookeeper_tls_test.py system test -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

[ 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

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

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

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

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 ->

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

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:

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

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

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 > >

Re: Permission to create a KIP

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! >

Re: Kafka Exactly-Once Semantics in .NET support

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 > >