Hello Alex,
Currently Kafka Connect has some simple "T" function on a per-message-basis
since 0.10 release, but that may not be sufficient for your use case.
We are planning to have some Kafka Streams / Connect integration in the
near future, so that users can specify non-Kafka sources / sinks in
Hi Clive,
We are working on exposing the state store behind a KTable as part of allowing
for queries to the structures currently hidden behind the language (DSL). The
KIP should be out today or tomorrow for you to have a look. You can probably do
what you need using the low-level processor API
Could Kafka please publish more OS packages, so it's easier for people to
install?
* Gentoo/emerge
* RedHat/rpm
* Debian/apt
--
Cheers,
Andrew
Even though I'm not aware of anyone working on it, I think we'd definitely
be open to it if someone wants to take a swing at it.
-Jay
On Sun, Jun 26, 2016 at 9:13 AM, Alex Glikson wrote:
> Hi all,
>
> I wonder whether there are plans to implement Apache Beam backend based on
> Kafka Streams?
>
can someone please explain why latency is so big for me？thanks
> 在 2016年6月25日，下午11:16，Jay Kreps 写道：
>
> Can you sanity check this with the end-to-end latency test that ships with
> Kafka in the tools package?
>
> https://apache.googlesource.com/kafka/+/1769642bb779921267bd57d3d338591dbdf33842/c
Since it is apparently ill-advised to use Kafka for long-term storage I'm
investigating ways to archive messages in a standardized way that adds the
least possible complexity overhead to consumer applications that may need
to process all data ever written to a topic before continuing to stream
mess
The broker shuts itself down. Once you've fixed the disk space issue (eg.
by attaching more disks) then it'll start back up just fine.
Thanks
Tom Crayford,
Heroku Kafka
On Mon, Jun 27, 2016 at 2:44 PM, Nomar Morado
wrote:
> Hi
>
> What is kaka's behavior if the partition it is running runs out
Hi
What is kaka's behavior if the partition it is running runs out of disk
space?
Do producers get error? Does the entire kafka stop running? etc...
Appreciate your help.
Thanks.
Anybody?
Chris
From: Chris Barlock/Raleigh/IBM@IBMUS
To: users@kafka.apache.org
Date: 06/24/2016 04:56 PM
Subject:Producer Properties
I started porting our code from Kafka 0.8.2.1 to 0.10.0.0 and found my
producer code blowing up because of some changes to the config. For
