Re: Processing time series data in order

How would I route the messages to a specific partition? On 27 Dec 2016 10:25 a.m., "Asaf Mesika" wrote: > There is a much easier approach: your can route all messages of a given Id > to a specific partition. Since each partition has a single writer you get > the ordering you wish for. Of course

Re: Retries not being run in KafkaProducer

Search the mailing list I wrote about it. I forked and applied the commit that fixed that. I'm waiting for a few months for 0.9.0.2 but still nothing- don't know what is taking so long if such an important bug is in the code. On Tue, 20 Dec 2016 at 22:55 Andrew Clarkson < andrew.clark...@rallyhealt

Re: Processing time series data in order

There is a much easier approach: your can route all messages of a given Id to a specific partition. Since each partition has a single writer you get the ordering you wish for. Of course this won't work if your updates occur in different hosts. Also maybe Kafka streams can help shard the based on it

Examples for Angular2 with kafka integration

Hi Team, Can you please provide any resource for Angular2 with Kafka integration examples.Thanks in advance. -- Regards, Sudheer

Log flush recommendation

Hi, I've been reading on log flush recommendations today and I have a question: Up until now I've been basing my production configuration for the log flush on this: http://kafka.apache.org/documentation/#prodconfig It works fine, but then I saw here http://kafka.apache.org/documentation/#top

Null Pointer Kafka Client

I am using kafka 0.10.1.0 some times on the client I've got null pointer exception: " java.lang.NullPointerException at org.apache.kafka.common.record.ByteBufferInputStream.read(org/apache/kafka/common/record/ByteBufferInputStream.java:34) at java.util.zip.CheckedInputStream.read(java/util

Re: What is difference between Kafka streaming and Samza?

Here are some differences between the two: - KafkaStreams is a library, whereas Samza is a framework, which makes the learning curve of KafkaStreams a bit easier. - Sources - KafkaStreams works with Kafka alone, while Samza can also be configured with Kinesis, ElasticSearch, HDFS and o

Kafka streams - Unable to initialize a timestamp extractor instance

Hi guys, I have an issue initializing a TimestampExtractor in KafkaStreams. The following (static) initialization works great: *config.put("timestamp.extractor", MyTimestampExtractor.class.getName());* But when trying to initialize with an instance of the class as follows: *config.put("timestamp