Couple of Questions related to kafka connections.
How to see producer and consumer connections to a specific broker?
How to kill a specific connection to a broker or cluster?
Dear contributors,
As part of a research team from Università della Svizzera italiana
(Switzerland) and University of Sannio (Italy), we have analyzed refactoring
pull requests in apache/kafka repository and are looking for developers for a
short 5-10 min survey
(https://usi.eu.qualtrics.com/j
Hi John,
Thanks for your answer.
Reading your suggestions forced me to reconsider one more time the
partitioner set on inputs. I already challenged all of them .. except one
input that was provided in my test infrastructure by kafkacat.
And it appears kafkacat is not using by default the same par
Hi,
May be this issue : https://issues.apache.org/jira/browse/KAFKA-9669 ?
-Message d'origine-
De : Satish Kumar
Envoyé : vendredi 7 août 2020 00:49
À : users@kafka.apache.org
Objet : compatible kafka version to use when using with logstash 7.5.1-1
Hello,
I upgraded kafka from 0.10 to
Hi Mathieu,
Aaah, that is a bummer. The littlest things can be
the hardest to find. Well, I'm glad I was able to
help in some capacity.
Cheers,
-John
On Tue, 2020-08-11 at 16:02 +0200, Mathieu D
wrote:
> Hi John,
>
> Thanks for your answer.
>
> Reading your suggestions forced me to reconsider
Yeah, I'd recommend upgrading to 2.5.1 (will be announced very soon) or
2.6.0.
Ismael
On Tue, Aug 11, 2020, 7:43 AM REYMOND Jean-max (BPCE-IT - SYNCHRONE
TECHNOLOGIES) wrote:
> Hi,
> May be this issue : https://issues.apache.org/jira/browse/KAFKA-9669 ?
>
> -Message d'origine-
> De : Sa
I configured Kafka to work over SSL without authorization.
I rebooted Kafka and I get a certificate on a test connection.
(openssl s_client -connect :9093)
But when I try to connect with the producer, I get an error - "failed
authentication due to: SSL handshake failed
(org.apache.kafka.client
Hi Ben,
Thanks for fixing that. Another problem I've just noticed is a couple of
garbled headings. E.g. scroll down from
https://kafka.apache.org/documentation.html#design_compactionbasics and the
"What guarantees does log compaction provide?" section is rendering as
$1 class="anchor-heading">$8$
The Apache Kafka community is pleased to announce the
release for Apache Kafka 2.5.1
This is a bug fix release, and it includes fixes and
improvements for 72 issues, including some critical bugs.
All of the changes in this release can be found in the
release notes:
https://www.apache.org/dist/kaf
Note that 2.5.1 has just been released.
Ismael
On Tue, Aug 11, 2020 at 7:54 AM Ismael Juma wrote:
> Yeah, I'd recommend upgrading to 2.5.1 (will be announced very soon) or
> 2.6.0.
>
> Ismael
>
> On Tue, Aug 11, 2020, 7:43 AM REYMOND Jean-max (BPCE-IT - SYNCHRONE
> TECHNOLOGIES) wrote:
>
>> Hi
Note that 2.5.1 has now been released.
Ismael
On Sun, Aug 2, 2020 at 11:13 AM Ismael Juma wrote:
> Hi Marina,
>
> If you upgrade to ZK 3.5.x, I highly recommend going with 3.5.8. It has a
> few critical fixes when compared to 3.5.6. Also, Kafka 2.5.1 should be out
> in a few days and I'd recomm
Hello Manoj,
I did kafka rolling upgrade and sorted out errors at both producer and consumer
side.
but logstash 7.5 is sending empty messages to my kafka brokers where as
logstash 2.4 is sending json messages normally(im seeing messages in kafka UI
tool)
what is the supported Kafka version wi
Thanks for driving the release John!
Guozhang
On Tue, Aug 11, 2020 at 1:40 PM John Roesler wrote:
> The Apache Kafka community is pleased to announce the
> release for Apache Kafka 2.5.1
>
> This is a bug fix release, and it includes fixes and
> improvements for 72 issues, including some critic
Thanks for driving the release John!
Ismael
On Tue, Aug 11, 2020 at 1:40 PM John Roesler wrote:
> The Apache Kafka community is pleased to announce the
> release for Apache Kafka 2.5.1
>
> This is a bug fix release, and it includes fixes and
> improvements for 72 issues, including some critical
Hi Team,
I am facing an issue in a clustered Kafka environment,
org.apache.kafka.common.KafkaException: Cannot perform send because at least
one previous transactional or idempotent request has failed with errors.
at
org.apache.kafka.clients.producer.internals.TransactionManager.failIfNotReadyF
Hi Team,
I am facing an issue in a clustered Kafka environment,
org.apache.kafka.common.KafkaException: Cannot perform send because at least
one previous transactional or idempotent request has failed with errors.
at
org.apache.kafka.clients.producer.internals.TransactionManager.failIfNotReadyF
Can you please share what action you are performing and how ?
On 8/11/20, 10:19 PM, "Indu V" wrote:
[External]
Hi Team,
I am facing an issue in a clustered Kafka environment,
org.apache.kafka.common.KafkaException: Cannot perform send because at
least one previous transact
We are inserting 50,000 records to Kafka from our application. Its a single
thread and transactional.
Regards,
Indu V
From: manoj.agraw...@cognizant.com
Sent: 12 August 2020 10:51
To: users@kafka.apache.org
Subject: Re: Finding consumer Lag
[External Email]: DO
Hi,
I wish to address an issue.
Certificates of Kafka broker in Control plane expired which impacted Kafka
Mirror maker service in all dataplanes. As a result, we renewed Kafka broker
certificates manually in Control plane which restored kafka mirror maker
service.
Short Term actions include:
Hi Tom, Ben,
PR is ready to address the issue you saw:
https://github.com/apache/kafka-site/pull/292
Thanks.
On Wed, Aug 12, 2020 at 1:09 AM Tom Bentley wrote:
> Hi Ben,
>
> Thanks for fixing that. Another problem I've just noticed is a couple of
> garbled headings. E.g. scroll down from
> http
"failed authentication due to: SSL handshake failed" --> Ensure having keys,
certificates and CA certificates in place; are the brokers connecting together
to discard issue in broker side?
"javax.net.ssl.SSLException: Unrecognized SSL message, plaintext connection?"
--> Having security.inter.br
21 matches
Mail list logo