Kafka consumer fetching metadata for topics failed -

-

i attempting write java client third party's kafka , zookeeper servers. able list , describe topics, when attempt read any, closedchannelexception raised. reproduce them here command line client.

$ bin/kafka-console-consumer.sh --zookeeper 255.255.255.255:2181 --topic eventbustopic [2015-06-02 16:23:04,375] warn fetching topic metadata correlation id 0 topics [set(eventbustopic)] broker [id:1,host:some_host,port:9092] failed (kafka.client.clientutils$) java.nio.channels.closedchannelexception                                            @ kafka.network.blockingchannel.send(blockingchannel.scala:100)                @ kafka.producer.syncproducer.liftedtree1$1(syncproducer.scala:73)             @ kafka.producer.syncproducer.kafka$producer$syncproducer$$dosend(syncproducer.scala:72)     @ kafka.producer.syncproducer.send(syncproducer.scala:113)                     @ kafka.client.clientutils$.fetchtopicmetadata(clientutils.scala:58)             @ kafka.client.clientutils$.fetchtopicmetadata(clientutils.scala:93)             @ kafka.consumer.consumerfetchermanager$leaderfinderthread.dowork(consumerfetchermanager.scala:66)     @ kafka.utils.shutdownablethread.run(shutdownablethread.scala:60)          [2015-06-02 16:23:04,515] warn fetching topic metadata correlation id 0 topics [set(eventbustopic)] broker [id:0,host:some_host,port:9092] failed (kafka.client.clientutils$) java.nio.channels.closedchannelexception                                            @ kafka.network.blockingchannel.send(blockingchannel.scala:100)                @ kafka.producer.syncproducer.liftedtree1$1(syncproducer.scala:73)             @ kafka.producer.syncproducer.kafka$producer$syncproducer$$dosend(syncproducer.scala:72)     @ kafka.producer.syncproducer.send(syncproducer.scala:113)                     @ kafka.client.clientutils$.fetchtopicmetadata(clientutils.scala:58)             @ kafka.client.clientutils$.fetchtopicmetadata(clientutils.scala:93)             @ kafka.consumer.consumerfetchermanager$leaderfinderthread.dowork(consumerfetchermanager.scala:66)     @ kafka.utils.shutdownablethread.run(shutdownablethread.scala:60)

alternate commands succeed:

$ bin/kafka-topics.sh --describe --zookeeper 255.255.255.255:2181 --topic eventbustopic topic:eventbustopic   partitioncount:2        replicationfactor:1     configs:     topic: eventbustopic  partition: 0    leader: 1       replicas: 1     isr: 1     topic: eventbustopic  partition: 1    leader: 0       replicas: 0     isr: 0  $ bin/kafka-topics.sh --list --zookeeper 255.255.255.255:2181 --topic eventbustopic eventbustopic

(the ips redacted , replaced 255.255.255.255)

when google exception, see issues on producer side -- indeed, source clientutils.fetchtopicmetadata suggests used producers.

one concern have might product of network layout: packets mangled haproxy , sent on vpn.

what @ work here?

the broker tells client hostname should used produce/consume messages. default kafka uses hostname of system runs on. if hostname can not resolved client side exception.

you can try setting advertised.host.name in kafka configuration hostname/address clients should use.


Comments

Post a Comment

Popular posts from this blog

python - TypeError: start must be a integer -

-
i trying draw 5 turtles, getting typeerror on line 25. here code: import turtle wn = turtle.screen() redrose = turtle.turtle() color = input("what background color be?") fillcolor_f = input("what color of rose be?") redrose.hideturtle() redrose.speed(30) redrose.penup() redrose.left(180) redrose.forward(175) redrose.right(90) redrose.forward(30) redrose.right(90) redrose.pendown() def drawrose(red): redrose.color("pink") redrose.fillcolor(fillcolor_f) redrose.fill(true) in range(red): redrose.forward(i) redrose.right(49) in range(5): drawrose(redrose) redrose.penup() redrose.forward(350) redrose.right(144) redrose.pendown() redrose.fill(false) drawrose(50) wn.bgcolor(color) i trying draw 5 roses, produces errors. doing in interactivepython.org. you recursively calling drawrose wrong parameter. on line 23 ( for in range(red): ) expect red integer...
Read more

c# - DevExpress RepositoryItemComboBox BackColor property ignored -

-
i have following code almost works properly; private void cbstatus_drawitem(object sender, listboxdrawitemeventargs e) { string item = e.item string; if (item != null) { switch (item) { case "1": e.appearance.forecolor = color.green; e.appearance.backcolor = color.green; break; case "2": e.appearance.forecolor = color.orange; e.appearance.backcolor = color.orange; break; case "3": e.appearance.forecolor = color.red; e.appearance.backcolor = color.red; break; } } } when dropdown shown, items forecolor correct, backcolor remains whatever backcolor of theme is; i.e. if i've got set dark theme, backcolor dark, cells in gridview, rather being green/orange/red. i've tried setting e.appearance.options.usebackcolor trying set e....
Read more

django - Creating multiple model instances in DRF3 -

-
1) create multiple model instances 1 api call, asked here: how create multiple model instances django rest framework? tried solution named in link, no success. i trying upload multiple files in 1 api call. result: files uploaded (only once overwrote perform_create) 1 instance created (if send 2 files, latter created instance). my code: class fileuploadserializer(serializers.modelserializer): def __init__(self, *args, **kwargs): many = kwargs.pop('many', true) super(fileuploadserializer, self).__init__(many=many, *args, **kwargs) class meta: model = fileupload read_only_fields = ('created', 'datafile', 'owner') class fileuploadviewset(viewsets.modelviewset): queryset = fileupload.objects.all() serializer_class = fileuploadserializer parser_classes = (multipartparser, formparser, ) def perform_create(self, serializer): file_list = self.request.data.getlist('file') ...
Read more