Hello All
I have been attempting to build an end-to-end example of producer with
multiple consumers using scala.
I managed to build a producer, but when I attempt to build a consumer the
following statement causes the scala REPL to block/hang
val consumerMap = consumer.createMessageStreams(topicC
I noticed that ProducerData has been removed in 0.8 branch
If I'd wish to send a complex message type (encoded message) ,
how would I do it in 0.8?
In 0.7.X (a snippet from Neha's example)
val producer = new Producer[Message, MemberRecord](config);
// send a single message
val mes
Hello,
Specified below is my code base where I am attempting to marshall a complex
type and receiving the follow error.
Am I missing anything here?
Sending Encoded Messages ..
[error] (run-main) java.lang.ClassCastException: java.lang.String cannot be
cast to com.test.groups.MemberRecord
java.la
Can anybody please help with this issue indicated below. I have not heard
from anyone with a solution.
Thanks in advance
Amar
On Tue, Jul 16, 2013 at 11:35 PM, prashant amar wrote:
> Hello,
>
> Specified below is my code base where I am attempting to marshall a
> complex type and receiving the
5 PM:
-
The June 14 patch set no longer applies cleanly. I've re-applied the patches to
the latest 0.8 branch and attached a new set as KAFKA-717-patches-20130720.tgz.
There is a separate patch per file for better shelf life.
To apply: git checkout 0.8; git apply *.patch
7 PM:
-
The June 14 patch set no longer applies cleanly. I've applied them to the
latest 0.8 branch and attached a new set as KAFKA-717-patches-20130720.tgz,
which includes one patch per file for better shelf life.
To apply: git checkout 0.8; git apply *.patch
wa
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Landahl updated KAFKA-717:
---
Attachment: KAFKA-717-patches-20130720.tgz
Patches to support building Kafka 0.8 with Scala 2.10
