Kafka

Hi Bruno, Thanks for your reply, I'm looking for a commercial support about services consulting like we can have in others Apache project like: https://camel.apache.org/manual/commercial-camel-offerings.html https://activemq.apache.org/support I think it could be nice to add this on the Kafka website. Regards, Francois On 28/09/2022 11:05, Bruno Cadonna wrote: > Hi Francois, > > I am not aware of such a page on the Apache Kafka website. > > There are a variety of companies that sell Kafka as a self-hosted > platform or as a Cloud-hosted service. > > Those companies include Confluent (disclaimer: I work for them), Red > Hat, AWS, Aiven, Instaclustr, Cloudera, and more. > > > Best, > Bruno > > On 28.09.22 10:38, fpapon wrote: >> Hi, >> >> I'm looking for a commercial support company page on the official >> website ( https://kafka.apache.org ) but I cannot find one. ...

Hi Francois, I am not aware of such a page on the Apache Kafka website. There are a variety of companies that sell Kafka as a self-hosted platform or as a Cloud-hosted service. Those companies include Confluent (disclaimer: I work for them), Red Hat, AWS, Aiven, Instaclustr, Cloudera, and more. Best, Bruno On 28.09.22 10:38, fpapon wrote: > Hi, > > I'm looking for a commercial support company page on the official > website ( https://kafka.apache.org ) but I cannot find one. > > Is such of page exist? > > Regards, > > Francois >

Hi, I'm looking for a commercial support company page on the official website ( https://kafka.apache.org ) but I cannot find one. Is such of page exist? Regards, Francois

I re-ran the failing system tests last night and got passing builds for each. There is still some flakiness it seems. Round trip test: http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/system-test-kafka-branch-builder--1664223686--apache--3.3--9b8a48ca2a/2022-09-26--001./2022-09-26--001./report.html Upgrade test: http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/system-test-kafka-branch-builder--1664235839--apache--3.3--1ce7bd7f29/2022-09-26--001./2022-09-26--001./report.html I was also able to verify that the failing delegation token test was not a regression, rather it was an issue with the test. I've opened a PR with a fix for the test https://github.com/apache/kafka/pull/12693 . Included in the PR are the results of this fix applied to the 3.3 branch (confirming we don't have a regression). I also filed a JIRA for the flaky upgrade_test https://issues.apache.org/jira/browse/KAFKA-1426...

Hi Namita, This is likely a listener configuration issue.  The bootstrap server setting only gets you so far, your client must be able to contact the server via a listener address.  I have seen this occur on a few systems where a hostname could not be identified by Kafka, so the server advertises a listener on only localhost:9092.  Since your producer is not on the same system, it will not connect. You can try updating the listeners and advertised.listeners properties in your server configuration file to use the actual hostname (assuming the producer can reach the server via the hostname). Example (assumes plaintext communication, replace PLAINTEXT if needed): listeners=PLAINTEXT:// myserver.acme.com:9092 advertised.listeners=PLAINTEXT:// myserver.acme.com:9092 I hope this helps, Jim Ziesig On Tue, Sep 27, 2022 at 3:25 AM Namita Jaokar < jaokarnamita9@gmail.com > wrote: Hi All, I am currently exploring a scenario where my producer and consumer are at different networks and ...

I upgraded to kafka streams 3.0.0 with positive task.max.idle.ms and it did not help. When lag is large, the application still consumes data batches without interleaving. wt., 27 wrz 2022 o 05:51 John Roesler < vvcephei@apache.org > napisał(a): > Hi Tomasz, > > Thanks for asking. This sounds like the situation that we fixed in Apache > Kafka 3.0, with KIP-695 ( > https://cwiki.apache.org/confluence/display/KAFKA/KIP-695%3A+Further+Improve+Kafka+Streams+Timestamp+Synchronization > ). > > Can you try upgrading and let us know if this fixes the problem? > > Thanks, > -John > > On Mon, Sep 26, 2022, at 01:35, Tomasz Gac wrote: > > Hi group, > > > > I wrote a simple kafka streams application with topology such as below: > > > > builder.addStateStore( > >> Stores.keyValueStoreBuilder( > >> Stores.persistentKeyValueStore("STORE"), > >> ...

++ Updates. On Tue, Sep 27, 2022 at 12:54 PM Namita Jaokar < jaokarnamita9@gmail.com > wrote: > Hi All, > > I am currently exploring a scenario where my producer and consumer are at > different networks and systems. > > Below is my scenario: > > My kafka producer is on a client network on a system that does not have > Apache kafka installed. > My Kafka consumer is on my network and my system. > I have the zookeeper and kafka server setup at the consumer system. > I want the producer to send data to the consumer which is on my network. I > have tried this case in my spring boot application. > It gives me an error stating [Producer clientId=producer-1] Connection to > node -1 (localhost/ 127.0.0.1:9092 ) could not be established. Broker may > not be available. > > How will I let my producer and consumer communicate in this case? > > What configurations are required to establish the connection ...