navailable. This limitation will be addressed in a future
>release of Kafka.
>
> Link to the related section on the docs:
> https://kafka.apache.org/documentation/#kraft_deployment
>
>
> Could you please clarify the following part?
> *"More than 3 controllers is no
network failure it is possible for the cluster metadata quorum
to become unavailable. This limitation will be addressed in a future
release of Kafka.
Link to the related section on the docs:
https://kafka.apache.org/documentation/#kraft_deployment
Could you please clarify the following part
Thanks for reporting this.
Are you interested in submitting a PR to fix it?
Guozhang
On Wed, May 18, 2022 at 7:26 AM Владимир Савостин
wrote:
> In section https://kafka.apache.org/quickstart#quickstart_kafkaconnect
> you should change plugin path from lib/connect-file-3.2.0.ja to
> libs/connec
In section https://kafka.apache.org/quickstart#quickstart_kafkaconnect
you should change plugin path from lib/connect-file-3.2.0.ja to
libs/connect-file-3.2.0.ja
Have a nice day!
In the docs, section "5.4 Log", there is a diagram with the title "Kafka
Log Implementation". The right column of the diagram depicts "Segment
Files": "topic/34477849968.kafka" at the top, "topic/82796232652.kafka"
at the bottom. Inside the file
Hi, Kafka.
While reading through protocol docs, I found that doc about protocol
evolution and versioning are missing in protocol.html, while toc contains a
section for it.
https://github.com/apache/kafka/blob/trunk/docs/protocol.html#L47-L50
Is there any plan to add a doc about protocol
You need to setup a local web server as described in the wiki:
https://cwiki.apache.org/confluence/display/KAFKA/Setup+Kafka+Website+on+Local+Apache+Server
-Matthias
On 9/26/19 8:28 AM, 944126367 wrote:
> I downloads a Binary package(kafka_2.12-2.3.0) and index.html in
> site-docs dir is
I downloads a Binary package(kafka_2.12-2.3.0) and index.html in site-docs dir
is can't be effective. like these pics.
I downloads a Binary package(kafka_2.12-2.3.0) and index.html in site-docs dir
is can't be effective. like these pics.
That's what i was after! Thanks a lot.
On 30 May 2018 at 17:29, Emmett Butler wrote:
> From the docs <https://kafka.apache.org/documentation/#impl_offsettracking
> >
> :
>
> > The brokers periodically compact the offsets topic since it only needs to
> > mai
Hello,
I was trying to remember from docs (it's been a while) how the last
committed offsets work i.e. whether it's being tracked per consumer
group-basis or something else. This is specific to when auto.offset.reset
is set to "earliest"/"latest" and the last
>From the docs <https://kafka.apache.org/documentation/#impl_offsettracking>
:
> The brokers periodically compact the offsets topic since it only needs to
> maintain the most recent offset commit per partition
Offsets are maintained per partition per consumer group, so it doesn
A consumer can read data from multiple topics. The above line describes the
usage of
topic regex in which an existing consumer can read data from newly (yet-to)
created topics.
For more details, see
https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscrib
Hi.
I read (mostly) all documentation top to bottom and happened to stumble
upon passage I cannot understand. It states:
https://kafka.apache.org/documentation/#impl_consumerregistration
"If the consumer creates a message stream using a topic filter, it also
registers a watch on changes (new top
Awesome, makes perfect sense thank you!
On 11/10/2017 07:28 PM, Kaufman Ng wrote:
I think "CLIENT" is just an example. The default for
listener.security.protocol.map doesn't have it. If you look at the KIP link
in my email there's a more complete example:
listener.security.protocol.map=CLIENT:
I think "CLIENT" is just an example. The default for
listener.security.protocol.map doesn't have it. If you look at the KIP link
in my email there's a more complete example:
listener.security.protocol.map=CLIENT:SASL_PLAINTEXT,REPLICATION:PLAINTEXT,INTERNAL_PLAINTEXT:PLAINTEXT,INTERNAL_SASL:SASL_P
Yep I'm familiar with that. Just curious where it's documented that, for
instance, the CLIENT listener is for client connections.
On Fri, Nov 10, 2017, 12:08 PM Kaufman Ng wrote:
> This is related to another config "listener.security.protocol.map" (since
> version 0.10.2.0). The CLIENT, PLAINTEX
This is related to another config "listener.security.protocol.map" (since
version 0.10.2.0). The CLIENT, PLAINTEXT, etc are defined as a
name-protocol mapping. So what you have in the listeners property (e.g.
CLIENT) must have an entry in the protocol map which determines which
protocol to use (e.g
I've been working with Kafka broker listeners and I'm curious is there
any documentation that explains what all of them apply to? Such as
CLIENT, PLAINTEXT, SASL/SSL, etc. I see the encryption part of the
documentation, but is it just inferred what these listeners apply to?
Thank you in advance!
Tks matthias, I did't consider about the situation you mentioned. you're
right.
one or more input topic can add to one single source node:
builder.addSource("source-1", "topic-1", "topic-2");
Or they can add to different source node:
builder.addSource("source-1", "topic-1");
builder.addSource("sou
Well. You can also ready multiple topics as a single KStream.
> builder.stream("topic-1", "topic-2")
Of course both topics must contain data with same key and value type.
For this pattern, there is only one source node.
There is no 1-to-1 relationship between input topics and source node,
and th
Kafka streams topology can define one or many SourceNode.
The picture on official document <
http://kafka.apache.org/0102/documentation/streams#streams_architecture_tasks
>
only draw one source node in some place:
1. Stream Partitions and Tasks
2. Threading Model
3. Local StateStore
And the topolo
Trevor Grant has invited you to view the following document:
Open in Docs
<https://accounts.google.com/o/oauth2/auth?client_id=1024674817942-fstip2shineo1lsego38uvsg8n2d3421.apps.googleusercontent.com&scope=https%3A%2F%2Fmail.google.com%2F+https%3A%2F%2Fwww.googleapis.com%2Fauth%2Fc
the address
from the dev mailing list. This address
is no longer a subscriber.
Guozhang
On Thu, Mar 23, 2017 at 11:23 AM, Zac Harvey wrote:
> Hi how do I unsubscribe from this mailist list, the details in the docs
> are not the correct set of steps.
>
&g
Hi how do I unsubscribe from this mailist list, the details in the docs are not
the correct set of steps.
From: Zac Harvey
Sent: Thursday, March 23, 2017 10:03:48 AM
To: users@kafka.apache.org
Subject: Mailing list docs are misleading/broken/outdated
I am
Hi, how do I unsubscribe from this mailing list.
From: Zac Harvey
Sent: Thursday, March 23, 2017 10:03:48 AM
To: users@kafka.apache.org
Subject: Mailing list docs are misleading/broken/outdated
I am trying to unsubscribe to this mailing list. When I go to
Any ideas?
From: Zac Harvey
Sent: Thursday, March 23, 2017 10:03:48 AM
To: users@kafka.apache.org
Subject: Mailing list docs are misleading/broken/outdated
I am trying to unsubscribe to this mailing list. When I go to:
https://kafka.apache.org/contact
Apache
about Kafka™. To
subscribe, send an ...
The docs say:
"To unsubscribe from any of these you just change the word "subscribe" in the
above to "unsubscribe"."
So if I try sending an email to users-unsubscr...@kafka.apache.org, I get SMTP
errors/failures (is n
pira wrote:
>>>
>>>> +1
>>>>
>>>> On Tue, Jan 31, 2017 at 5:57 PM, Matthias J. Sax <
>> matth...@confluent.io>
>>>> wrote:
>>>>> Hi,
>>>>>
>>>>> I want to collect feedback about the i
> > +1
> > >
> > > On Tue, Jan 31, 2017 at 5:57 PM, Matthias J. Sax <
> matth...@confluent.io>
> > > wrote:
> > > > Hi,
> > > >
> > > > I want to collect feedback about the idea to publish docs for current
> > &g
i,
> > >
> > > I want to collect feedback about the idea to publish docs for current
> > > trunk version of Apache Kafka.
> > >
> > > Currently, docs are only published for official release. Other projects
> > > also have docs for current SNAPSHOT
Thanks for bringing this up, Matthias.
+1
On Wed, Feb 1, 2017 at 8:15 AM, Gwen Shapira wrote:
> +1
>
> On Tue, Jan 31, 2017 at 5:57 PM, Matthias J. Sax
> wrote:
> > Hi,
> >
> > I want to collect feedback about the idea to publish docs for current
>
+1
On Tue, Jan 31, 2017 at 5:57 PM, Matthias J. Sax wrote:
> Hi,
>
> I want to collect feedback about the idea to publish docs for current
> trunk version of Apache Kafka.
>
> Currently, docs are only published for official release. Other projects
> also have docs for cur
+1
On 1 Feb 2017 07:27, "Matthias J. Sax" wrote:
> Hi,
>
> I want to collect feedback about the idea to publish docs for current
> trunk version of Apache Kafka.
>
> Currently, docs are only published for official release. Other projects
> also have docs for c
Hi,
I want to collect feedback about the idea to publish docs for current
trunk version of Apache Kafka.
Currently, docs are only published for official release. Other projects
also have docs for current SNAPSHOT version. So the question rises, if
this would be helpful for Kafka community, too
Hello Apache Kafka community,
Is it intentional that not all states (like ReplicaDeletionIneligible) are
documented on
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Controller+Internals
or is the page just outdated?
Btw I see replica states documented in javadoc
https://github.com/apach
All,
Here's a first spike.. would love feedback.. happy to continue the convo
here (https://issues.apache.org/jira/browse/KAFKA-2967)
http://christianposta.com/kafka-docs/_book/index.html
have the gitbook build integrated with the kafka gradle builds and rest of
WIP here:
https://githu
org/jira/browse/KAFKA-2967 ?
> >
> > Gwen
> >
> > On Wed, Mar 2, 2016 at 2:39 PM, Christian Posta
> > > wrote:
> > > Would love to have the docs in gitbook/markdown format so they can
> easily
> > > be viewed from the source repo (or mirro
> wrote:
> > Would love to have the docs in gitbook/markdown format so they can easily
> > be viewed from the source repo (or mirror, technically) on github.com.
> They
> > can also be easily converted to HTML, have a side-navigation ToC, and
> still
Hey!
Yes! We'd love that too! Maybe you want to help us out with
https://issues.apache.org/jira/browse/KAFKA-2967 ?
Gwen
On Wed, Mar 2, 2016 at 2:39 PM, Christian Posta
wrote:
> Would love to have the docs in gitbook/markdown format so they can easily
> be viewed from the sour
Would love to have the docs in gitbook/markdown format so they can easily
be viewed from the source repo (or mirror, technically) on github.com. They
can also be easily converted to HTML, have a side-navigation ToC, and still
be versioned along with the src code.
Thoughts?
--
*Christian Posta
urability Guarantees", mentions ability to disable
> > unclean leader election, so likely just this one reference needs to be
> > updated.
> >
> > On Sat, Sep 12, 2015 at 1:05 AM, Guozhang Wang
> wrote:
> >
> > > Hi Stevo,
> > >
> > &g
2, 2015 at 1:05 AM, Guozhang Wang wrote:
>
> > Hi Stevo,
> >
> > Could you point me to the link of the docs?
> >
> > Guozhang
> >
> > On Fri, Sep 11, 2015 at 5:47 AM, Stevo Slavić wrote:
> >
> > > Hello Apache Kafka community,
> >
mentions ability to disable
unclean leader election, so likely just this one reference needs to be
updated.
On Sat, Sep 12, 2015 at 1:05 AM, Guozhang Wang wrote:
> Hi Stevo,
>
> Could you point me to the link of the docs?
>
> Guozhang
>
> On Fri, Sep 11, 2015 at 5:47 AM, Stev
Hi Stevo,
Could you point me to the link of the docs?
Guozhang
On Fri, Sep 11, 2015 at 5:47 AM, Stevo Slavić wrote:
> Hello Apache Kafka community,
>
> Current unclean leader election docs state:
> "In the future, we would like to make this configurable to better support
Hello Apache Kafka community,
Current unclean leader election docs state:
"In the future, we would like to make this configurable to better support
use cases where downtime is preferable to inconsistency. "
If I'm not mistaken, since 0.8.2, unclean leader election strategy (whet
Those APIs are not implemented in 0.8.2. They were included because the
APIs were being iterated on, but the implementation wasn't there yet.
You can expect to see those APIs (with some modifications as they've been
refined) in 0.8.3.
-Ewen
On Sun, Sep 6, 2015 at 10:42 AM, Phil Steitz wrote:
>
is the javadoc for the 0.8.2 Java consumer API published somewhere?
All I can find on the website is the producer API, but there are
some consumer classes mentioned on the website and more in the
source distribution under
src/main/java/org/apache/kafka/clients/consumer.
0.9, will look like
http://people.apache.org/~nehanarkhede/kafka-0.9-consumer-javadoc/doc/
Hope that is useful!
Thanks,
Neha
On Thu, Apr 10, 2014 at 8:14 PM, Jun Rao wrote:
> We don't have good java docs right now. We are rewriting both the producer
> and the consumer and will
We don't have good java docs right now. We are rewriting both the producer
and the consumer and will have better javadoc then. For now, following the
examples in the documentation is probably your best option.
Thanks,
Jun
On Thu, Apr 10, 2014 at 11:43 AM, Manoj Khangaonkar
wrote:
Hi,
The API description at http://kafka.apache.org/documentation.html#api is
rather thin -- when you are used to the API docs of other apache projects
like hadoop , cassandra , tomcat etc etc.
Is there a comprehensive API description somewhere (like javadocs) ?
Besides looking at the source
Thanks for pointing this out. Updated the doc.
The reason for the change is the following. If the timeout is caused by a
problem at the broker, It's actually not very useful to set the timeout too
small. After timing out, the producer is likely to resend the data. This
adds more load to the broker
Seems the default for this is no 1
Online doc shows 1500
Just curious, why was this value updated?
Jason
Hey All,
We've been trying to improve the Kafka docs over the last month. Two things
that would really help:
1. If you see something answered that seems like it might be a common
question, add it to the FAQ. Right now only a couple people are doing this,
but it would be great if everyone d
54 matches
Mail list logo
