Alerting on Kafka certificate

2020-08-03 Thread Aninditya SAHA
Hi, I wish to address a problem that I was facing few days back. Here's the problem statement: 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

Re: [VOTE] 2.6.0 RC2

2020-08-03 Thread Randall Hauch
+1 (non-binding) I'm closing the vote since this has met the release criteria. Randall On Mon, Aug 3, 2020 at 2:57 AM Ismael Juma wrote: > +1 (binding), verified signatures, ran the tests on the source archive with > Scala 2.13 and Java 14 and verified the quickstart with the source archive >

Re: How to use SMT to add header in my messages?

2020-08-03 Thread DaveKlein_USA
Hello, I’m not sure if you are the same person, or work with the person who posted a similar question on Slack, but, just in case this is an unrelated coincidence… You should be able to use ConnectRecord.header().add() to add a header. I’ve used something similar to read headers on incoming

Re: Help - Issue with Kafka Machines

2020-08-03 Thread 宋英拴
Hi Manoj, The logs just seems the follower replicas of topic-partition `psvc-global-data-0` are all out of ISR(In-Sync replica), so the ISR is 1 now. And the config `min.insync.replicas` of this topic was set to 2, which means the minimum number of replicas that must acknowledge a write for the

Re: [VOTE] 2.5.1 RC0

2020-08-03 Thread Mickael Maison
+1 (binding) - built from source with Scala 2.12 and Java 8 - ran quickstart - verified signatures Thanks John for running this release On Fri, Jul 31, 2020 at 6:40 PM Manikumar wrote: > > Hi John, > > +1 (binding) > > - Verified signatures, artifacts, Release notes > - Built from sources,

How to use SMT to add header in my messages?

2020-08-03 Thread vishnu murali
Hi everyone I am getting data from SFTP CSV Source connector. In this I need to add header with that message for consuming in Java side. So anyone knows how to add header in the message while using connector? Thanks in advance .

Re: Some conceptual and administrational question

2020-08-03 Thread 宋英拴
hi hamidreza, Here are some of my views on your question and all my answer is based on Kafka-1.0.1: 1. This function is probably not off the shelf in kafka 1.0.1 and you need to do this yourself if you really need this. However, u can get the start and end offsets of one specific partition by

Re: [VOTE] 2.6.0 RC2

2020-08-03 Thread Ismael Juma
+1 (binding), verified signatures, ran the tests on the source archive with Scala 2.13 and Java 14 and verified the quickstart with the source archive and Scala 2.13 binary archive. Thanks, Ismael On Tue, Jul 28, 2020, 2:52 PM Randall Hauch wrote: > Hello Kafka users, developers and

Topic labels / metadata

2020-08-03 Thread Ross Black
Hi, I looked through documentation etc but could not find anything... Is it possible to attach arbitrary labels / metadata to individual topics? Is there a plan to do this? Is this a feature that others would be interested in, or is there an alternative that I am missing? I am looking at it