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 from
+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 client-deve
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
kafka
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 😊.
+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, ran
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
wri
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
+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
>
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 res
