Interact with kafka docker container from outside of docker host -


i have built kafka docker container , orchestrate using docker-compose.

calling docker ps following putput:

container id        image                          command                created             status              ports                                         names     5bde6f76246e        hieutrtr/docker-kafka:0.0.1    "/start.sh"            hour ago   hour    7203/tcp, 0.0.0.0:32884->9092/tcp             dockerkafka_kafka_3     be354f1b8cc0        hieutrtr/docker-ubuntu:devel   "/usr/bin/supervisor   hour ago   hour    22/tcp                                        producer1     50d3203af90e        hieutrtr/docker-kafka:0.0.1    "/start.sh"            hour ago   hour    7203/tcp, 0.0.0.0:32883->9092/tcp             dockerkafka_kafka_2     61b285f39615        hieutrtr/docker-kafka:0.0.1    "/start.sh"            2 hours ago         2 hours          7203/tcp, 0.0.0.0:32882->9092/tcp             dockerkafka_kafka_1     20c9c5ccec05        jplock/zookeeper:3.4.6         "/opt/zookeeper/bin/   2 hours ago         2 hours          2888/tcp, 3888/tcp, 0.0.0.0:32881->2181/tcp   dockerkafka_zookeeper_1

i can run producer , consumer inside docker container, not working outside docker network.

for example:

i run kafka producer on localhost , following error appears:

$ kafka_2.9.1-0.8.2.1: bin/kafka-console-producer.sh --topic test --broker-list $docker_host:32884 [2015-08-31 06:55:15,450] warn property topic not valid (kafka.utils.verifiableproperties) [2015-08-31 06:55:20,214] warn failed send producer request correlation id 2 broker 1 data partitions [test,0] (kafka.producer.async.defaulteventhandler) 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$$anonfun$send$1$$anonfun$apply$mcv$sp$1.apply$mcv$sp(syncproducer.scala:103)     @ kafka.producer.syncproducer$$anonfun$send$1$$anonfun$apply$mcv$sp$1.apply(syncproducer.scala:103)     @ kafka.producer.syncproducer$$anonfun$send$1$$anonfun$apply$mcv$sp$1.apply(syncproducer.scala:103)

this kafka docker example on github includes mentioned problem.

so, experiencing same problems , can me in way?

additional info:

(just fork ches/kafka , modify docker-compose) :

in kafka server properties need set advertised.host.name , advertised.portto ip/port of running container , should work.


-

Comments

Post a Comment

Popular posts from this blog

c# - Binding a comma separated list to a List<int> in asp.net web api -

the default binder in web api expecst http://url.com/webapi/report/?pageids=3243&pageids=2365 to bind public ihttpactionresult report(list<int> pageids){ // exciting webapi code} i wish bind http://url.com/webapi/report/?pageids=3243,2365 as running out of space in url get . i have created class public class commaseparatedmodelbinder : system.web.http.modelbinding.imodelbinder { public bool bindmodel(httpactioncontext actioncontext, modelbindingcontext bindingcontext) { //binding in here } } and registered in webapiconfig.cs var provider = new simplemodelbinderprovider( typeof(list<int>), new commaseparatedmodelbinder()); config.services.insert(typeof(modelbinderprovider), 0, provider); i have altered method signature use model binder so public ihttpactionresult report( [modelbinder] list<int> pageids){ // exciting webapi code} however break point in binder not being ...
Read more

how to prompt save As Box in Excel Interlop c# MVC 4 -

i want export excel sheet using excel interloop... i have datatable convert excel sheet... now there way save file using save dialogue box in mvc 4 here code public string datatabletoexcel(datatable dt, string htmlheading, string key) { try { microsoft.office.interop.excel.application excel; microsoft.office.interop.excel.workbook excelworkbook; microsoft.office.interop.excel.worksheet excelsheet; microsoft.office.interop.excel.range excelcellrange; excel = new microsoft.office.interop.excel.application(); excel.visible = false; excel.displayalerts = false; excelworkbook = excel.workbooks.add(type.missing); excelsheet = (microsoft.office.interop.excel.worksheet)excelworkbook.activesheet; excelsheet.name = "sheet1"; dataset ...
Read more

xslt 1.0 - How to access or retrieve mets content of an item from another item? -

my use case have item has link in item. example, item 123456789/152 has metadata field dc.relation.hasversion=123456789/717 . within item view of 123456789/152 , how can retrieve values of metadata of 123456789/717 ? example, want retrieve dc.language.iso value of 123456789/717 123456789/152 . i looked @ related items feature in dspace don't know how metadata displayed in related items list pulled items in list. i using dspace version 5.3 mirage 2 theme . edit based on schweerelos answer, below actual code. using custom metadata field dc.relation.languageversion . basically, want link other version instead of displaying value, display dc.language.iso of other version in item-view.xsl . i've incorporated answer of schweerelos question in code just displaying value of dc.relation.languageversion . sample values of dc.relation.languageversion 10665.1/9843 ; 10665.1/9844 ie not complete uri handle. thanks in advance! actual code <xsl:template name=...
Read more