Hello,
I just had a weird problem in one of my topics.
It accepted messages from producers but consumers couldn't see those
messages. The producers didn't get any errors when sending messages to
the topic, but even my test-console-consumer didn't see anything in the
topic.
Also checking the t
Hi Community,
I am accessing events from the enterorise Kafka topics via Windows command line
via keytab successfully. However, I have transitioned to macbook this week and
the same set of commands are not working in Mac. Any documentation on how to
connect to kafka topic via macbook and using k
Hi all,
I put together a draft release plan with Oct 2019 as the release month and
a list of KIPs that have already been voted:
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=125307901
Here are the dates:
1) KIP Freeze: Sep 25, 2019 (A KIP must be accepted by this date in ord
FYI:
I changed the dependencies of brooklin to use kafka 0.10.0.1.
But compilation is getting failed.
1st failure related test case where it trying to create KafkaServer, where
constructor args mismatch.
I have changed KafkaServer creation API to old one, but another set of
issues:
brooklin having
Hi Eliza,
I used the wrong word stability. Rather it should be a byzantine fault tolerant
network.
Regards,
Soumya
-Original Message-
From: Eliza
Sent: Tuesday, August 27, 2019 12:55 PM
To: users@kafka.apache.org
Subject: Re: Byzantine Fault Tolerance Implementation
Hi
on 2019/8/27
Hi Liam,
Thank you for you kind reply. I will check it out to see if this helps.
There are amost 5K topics in our cluster with 6 nodes. We collect the
metrics by collectd (https://collectd.org/) and visualize with Grafana. If
all these per topic metrics are collected, will it affect the performan
Hi,
The broker exposes per topic error rates, that might help?
https://docs.confluent.io/current/kafka/monitoring.html#per-topic-metrics
Kind regards,
Liam Clarke
On Tue, 27 Aug. 2019, 8:07 pm 李海军, wrote:
> Hi all,
>
> We have a kafka cluster consisted of 6 brokers with the version of
> kaf
Hi all,
We have a kafka cluster consisted of 6 brokers with the version of
kafka_2.11-0.10.2.1. These days we saw a continuous increasing on the
metrics of "BytesRejectedPerSec" on broker 1. I already knew that this
could happen when the message records were too large and raise a
"RecordTooLargeEx
Hi
on 2019/8/27 12:36, Nayak, Soumya R. wrote:
Zookeeper uses a version of Paxos - Zookeeper atomic broadcast. Is there any
plan in future or current in progress where zookeeper will be implemented with
a BFT algorithm. This might help to have a more stable distributed environment
when we hav
