Hi,
I observed some error messages / exceptions while running partition
reassignment on kafka 0.8.1.1 cluster. Being fairly new to this system I'm
not sure if these indicate serious failures or transient problems, or if
manual intervention is needed.
I used kafka-reassign-partitions.sh to reassig
2, 2014 at 11:20 PM, Jun Rao wrote:
> Is there an easy way to reproduce the issues that you saw?
>
> Thanks,
>
> Jun
>
> On Mon, Dec 1, 2014 at 6:31 AM, Karol Nowak wrote:
>
> > Hi,
> >
> > I observed some error messages / exceptions while running partiti
Hello!
Is it possible to send an array of String by Kafka Producer object. I want
to take some messages from 'topic1' - lines of text then split it to single
words and send it to another topic. I tried to use foreach loop over
msg.toString.split("//+") but it didn't help me.
object KafkaConsumer
Hi!
I have a problem with receiving and sending messages. My pipeline is:
- I get lines of words: "x xxx xx x"
- I want to split it into single words and send also as single message.
When I did something like this:
There is an error that can not resolve .runWith with such signatu
