1. There is not API for this
2. I guess it might be possible, but might not be the best way to do it.
3. That is also not possible.
I would recommend something like this:
> final AtomicBoolean shutdown = new AtomicBoolean(false);
>
> StreamsBuilder builder = ...
>
> KStream stream = builder
I create https://issues.apache.org/jira/browse/KAFKA-7380 to track this.
-Matthias
On 8/27/18 12:07 PM, Guozhang Wang wrote:
> Hello Patrik,
>
> Thanks for the email and this is indeed a good question! :)
>
> There are some historic reasons that we did the global state restoration in
> a differ
You can figure out the names via
builder.build().describe()
The naming pattern is
--[repartition|changelog]
You will also need to create those topic with the correct number of
partitions (usually the number of input topic partitions).
With this information, you can pre-create the topics and Kaf
Hi Robin,
The AdminClient is what you want.
"Evolving" is just a heads-up that the API is relatively new and hasn't
stood the test of time, so you shouldn't be *too* surprised to see it
change in the future.
That said, even APIs marked "Evolving" need to go through the KIP process
to be changed,
Hi Meeiling,
It sounds like "formal process" is more like "fill out a form beforehand"
than just "access controlled".
In that case, although it's somewhat of an internal detail, I think the
easiest thing would be to figure out what the name of the internal topics
will be and request their creatio
@M.Manna - thanks for your reply.
I did read that document but clearly didn't digest that bit properly.
@Liam Clarke
I don't expect code's users (either maintainers or end-users) to need
to deduce *anything*. If it needs knowing, I documented it.
I'll send you an actual example so you know it's n
Hi Jan,
.sh is not .bat and easily googleable.
Nothing is terrifying about updating the documentation, I just took umbrage
at you "resenting" your 3 days you expended on learning the hard way that
Windows is the minority market share in servers - you're resenting a free
open source project? Becau
I believe this needs to be articulated a bit more, which is not a big
issue. The common practice for a large-scale distributed system is to use
Linux servers, and it's always been a popular choice. That doesn't mean the
Windows is ignored. The issue at hand is that file deletion/renaming seems
to h
Hi Liam,
as a DB guy that does MSSQL (on windows, obviously) I literally have
no idea what a .sh file is,or what that would imply. I guess it's bash
so yeah.
But what's so terrifying about actually stating in the FAQ that you
should not run it as production on windows?
Why should I conclude that k
Hi,
In testing - i’ve got a 5 node Kafka cluster with min.insync.replicas set to 4.
The cluster is currently running version 0.10.0.1.
There’s an application that publishes to a topic - and on restart, it attempts
to read the full contents of the topic up until the high watermark before then
10 matches
Mail list logo
