spring - cant connect to kafka from external machine -


i´m starting apache kafka , i´m facing problems when try conect external machine.

with configuration bellow, works fine if application , docker running @ same machine.

but when put application in machine , docker @ machine b, application cant connect.

my spring kafka @configuration have line @bean consumerfactory , producerfactory (imagine machine docker ip = 10.10.10.10)

props.put(consumerconfig.bootstrap_servers_config, "10.10.10.10:9092");

and docker file this:

version: '2' services: zookeeper:     image: wurstmeister/zookeeper:3.4.6     ports:       - 2181:2181 kafka:     image: wurstmeister/kafka:0.10.1.1     environment:         kafka_advertised_host_name: 0.0.0.0         kafka_advertised_port: 9092         kafka_zookeeper_connect: zookeeper:2181         kafka_create_topics: "topic-jhipster:1:1,process_order:1:1, process_channel:1:1"         jmx_port: 9999         kafka_jmx_opts: "-dcom.sun.management.jmxremote -dcom.sun.management.jmxremote.authenticate=false -dcom.sun.management.jmxremote.ssl=false -djava.rmi.server.hostname=127.0.0.1 -dcom.sun.management.jmxremote.rmi.port=9999"     ports:         - 9092:9092         - 9999:9999 kafka-manager:     image: sheepkiller/kafka-manager     ports:         - 9000:9000     links:         - zookeeper     environment:         zk_hosts: zookeeper:2181

i error:

org.springframework.kafka.core.kafkaproducerexception: failed send; nested exception org.apache.kafka.common.errors.timeoutexception:  expiring 1 record(s)

edit, add information..

i think configuration zookeeper i´m missing .. because if have zookeeper started @ machine .. , kafka in machine b.. works.. don´t know how :(

try setting listeners,

eg: listeners = plaintext://your.host.name:9092

assuming can telnet between machines on kafka port.


Comments

Post a Comment

Popular posts from this blog

javascript - Create a stacked percentage column -

i have collection of data : var data = [ {"p301a":"10","p301b":"7","p301c":"7","p301d":"3","p301e":"8","p301f":"8","p301g":"8","p301h":"8","p301i":"8","p301j":"8","p301k":"8","p301l":"8","p301m":"8","p301n":"8","p301o":"8","age":"31-40 years","profesion":"2","position":"2"}, {"p301a":"5","p301b":"4","p301c":"4","p301d":"4","p301e":"4","p301f":"4","p301g":"4","p301h":"4","p301i":"4","p301j":"4","p301k":"4...
Read more

Optimising Firebase database by automatically overwriting data -

in firebase app have following structure: posts latest all users can write posts > latest . want limit entries 20 posts save space in database. , posts beyond 20 unnecessary never shown on homepage. how can limit posts 20, when user writes posts > latest posts @ end drop off (be deleted) automatically? this sample should you. you need : const max_log_count = 20; exports.removeold = functions.database.ref('/posts/latest/{postid}').oncreate(event => { const parentref = event.data.ref.parent; return parentref.once('value').then(snapshot => { if (snapshot.numchildren() >= max_log_count) { let childcount = 0; const updates = {}; snapshot.foreach(function(child) { if (++childcount <= snapshot.numchildren() - max_log_count) { updates[child.key] = null; } }); // update parent. removes children. ...
Read more

javascript - Angular UI-Grid customTemplate directive causing rows to load slowly/? -

Image
each grid cell can have more 1 customtemplate loaded. have directive holds watcher on model_col_field listen cell updates on scroll when dom rows updated , recompile celltemplate . without watcher , $compile rows repeat on scroll, showing same set of rows. is there more angular way of approaching or way improve performance? relevant controller code: create gridoptions.data & gridoptions.columndefs : var customtemp = '<div ng-repeat="opt in grid.appscope.colvalueoptionsmodel" ng-init="tempstring=model_col_field.clazz+opt.key;"><comparison-directive dbo="model_col_field" attobj="opt" fff="grid.appscope.getattributetemplate(tempstring)" /></div>'; $scope.gridoptions.columndefs = [ { name:'yindex',pinnedleft:true,celltemplate: customtemp, displayname:'index'}, { name:'col1',celltemplate: customtemp}, { name:'col2',celltemplate: c...
Read more