Still struggling :)
Check following threads;
- If my producer producing, then why the consumer couldn't consume? it
stuck @ poll()
- Consumer thread is waiting forever, not returning any objects
I think new APIs are recommended.
On 4 April 2016 at 16:37, Lohith Samaga M wrote:
> Tha
Thanks for letting me know.
Is there any work around? A fix?
Which set of API is recommended for production use?
Best regards / Mit freundlichen Grüßen / Sincères salutations
M. Lohith Samaga
-Original Message-
From: Ratha v [mailto:vijayara...@gmail.com]
Sent: Monday, April 04, 201
when I list down the partition info ;
List info = consumer.partitionsFor(topic);
it returns info like;
[Partition(topic = *MY_TOPIC*, partition = 0, leader = 1012, replicas =
[1012,], isr = [1012,]]
My communication with the broker looks like fine. I see more than 1000
messages for the topic
Thanks Gerad
On 4 April 2016 at 15:49, Gerard Klijs wrote:
> Yes, but only via the broker you connect to.
>
> On Mon, Apr 4, 2016, 07:10 Ratha v wrote:
>
> > I'm not seeing such parameter as an input for consumer.
> >
> > Does version 0.9.x use zookeeper?
> >
> > --
> > -Ratha
> > http://vvrath
I too face same issue:(
On 4 April 2016 at 15:51, Lohith Samaga M wrote:
> HI,
> Good morning.
>
> I am new to Kafka. So, please bear with me.
> I am using the new Producer and Consumer API with Kafka
> 0.9.0.1 running on Windows 7 laptop with zook
HI,
Good morning.
I am new to Kafka. So, please bear with me.
I am using the new Producer and Consumer API with Kafka 0.9.0.1
running on Windows 7 laptop with zookeeper.
I was able to send messages using the new Producer API. I can
Yes, but only via the broker you connect to.
On Mon, Apr 4, 2016, 07:10 Ratha v wrote:
> I'm not seeing such parameter as an input for consumer.
>
> Does version 0.9.x use zookeeper?
>
> --
> -Ratha
> http://vvratha.blogspot.com/
>
2016-04-04 7:20 GMT+09:00 Guozhang Wang :
> Hi Yuto,
>
> Is the destination topic embedded as part of the value in the original
> "foo" topic? If yes could you just access that field directly instead of
> mapping to a (key, value, destination) triplet?
>
Nope. KeyValueWithDestination is just an ex
I'm not seeing such parameter as an input for consumer.
Does version 0.9.x use zookeeper?
--
-Ratha
http://vvratha.blogspot.com/
Hi all;
Im publishing to the remote kafka server and try to consume messages from
that remote server. (Kafka v 0.90.1)
Publishing works fine but nor the consuming.
*Publisher*
package org.test;
*import java.io.IOException;*
*import java.util.Properties;*
*import org.apache.kafka.clients.produce
Sorry my bad..my kafka docker instance was down..
thanks
On 4 April 2016 at 10:09, Ratha v wrote:
>
> Hi all;
> I'm getting above exception when i try to produce simple string messages
> using kafka 0.9.01 version. I could not produce messages now.
>
> The warning i get is;
>
> buffer.memory =
On Fri, Apr 1, 2016 at 12:23 AM, Paolo Patierno wrote:
> Hi Ewen,
>
> thanks for your reply.
>
> My objective here is to access Kafka through AMQP protocol (now I'm
> working on a bridge from scratch without using Kafka Connect).
>
> Consider the following scenario ...
>
> Producer side :
>
> An
Hi all;
I'm getting above exception when i try to produce simple string messages
using kafka 0.9.01 version. I could not produce messages now.
The warning i get is;
buffer.memory = 33554432
timeout.ms = 3
key.serializer = class
org.apache.kafka.common.serialization.StringSerializer
sasl.ke
Hey Tony,
Are you connecting to Remote machine for Consumer and Producer? If yes try
to check the network bandwidth.
Do check the cluster configuration, memory, cpu resources, topic
partitions, replication factor, you would get some trace.
Thanks!
VM
On Apr 4, 2016 5:09 AM, "LeiNing" wrote:
>
Hi guys,
Hope you are doing well.
I'm encountering a performance issue and would be highly appreciate if you can
shed some light.
There is no problem by only running producer or consumer, but when I run both
of them at the same time, the performance is getting very slow.
What p
Hi Yuto,
Is the destination topic embedded as part of the value in the original
"foo" topic? If yes could you just access that field directly instead of
mapping to a (key, value, destination) triplet?
Guozhang
On Sun, Apr 3, 2016 at 9:29 AM, Yuto KAWAMURA
wrote:
> Hi Guozhang,
>
>
>
> 2016-04-
Yifan,
Are you on 0.8.0 or 0.8.1/2? There are some issues with zkVersion checking
in 0.8.0 that are fixed in later minor releases of 0.8.
Guozhang
On Fri, Apr 1, 2016 at 7:46 PM, Yifan Ying wrote:
> Hi All,
>
> We deleted a deprecated topic on Kafka cluster(0.8) and started observing
> constan
There are some discussions in maintaining client compatibility across
broker versions, where the main idea is to allow clients to retrieve the
broker version programmatically (details in KIP-35).
As for now although clients and servers are released together they each can
be treated as different ve
Hi Guozhang,
2016-04-02 3:29 GMT+09:00 Guozhang Wang :
> Hi Yuto,
>
> That is a good suggestion, the child index is not very intuitive from
> programmer's view and we can even consider replacing it with the processor
> name instead of overloading it. Could you file a JIRA?
>
Yep :) https://issu
Hi Tommy,
I think it's reasonable to think it should work. However, our upgrade tests
don't currently test that scenario and that is why we only mention
{0.8.2.x, 0.9.0.x} to 0.10.0.0:
https://github.com/apache/kafka/blob/trunk/tests/kafkatest/tests/upgrade_test.py#L62
The best way to verify wou
20 matches
Mail list logo
