hi,

I've tried the new version of the transport. server.js starts perfectly.
But when trying to run the client.js I'm getting the following error. i am using server and client fomr /test/ folder of the kafka transport. and setConfig to initialize the topics in kafka.

C:\Projects\Playground\EventBus\test1\EventBusTest1\EventBusTest1>node client.js
2014-04-29T21:03:41.810Z INFO hello Seneca/0.5.17/khkkeq
2014-04-29T21:03:42.619Z INFO plugin kafka-transport - ren96c client pubsub localhost 11300 Seneca/0.5.17/khkkeq

C:\Projects\Playground\EventBus\test1\EventBusTest1\EventBusTest1\node_modules\seneca-kafka-transport\node_modules\kafkaesque\lib\kafkaesque
.js:48
return params.host + '_' + params.port;
^
TypeError: Cannot read property 'host' of undefined
at _makeBrokerKey (C:\Projects\Playground\EventBus\test1\EventBusTest1\EventBusTest1\node_modules\seneca-kafka-transport\node_modules\ka
fkaesque\lib\kafkaesque.js:48:18)
at C:\Projects\Playground\EventBus\test1\EventBusTest1\EventBusTest1\node_modules\seneca-kafka-transport\node_modules\kafkaesque\lib\kaf
kaesque.js:121:23
at Object.callback (C:\Projects\Playground\EventBus\test1\EventBusTest1\EventBusTest1\node_modules\seneca-kafka-transport\node_modules\k
afkaesque\lib\kafkaesque.js:56:85)
at Socket. (C:\Projects\Playground\EventBus\test1\EventBusTest1\EventBusTest1\node_modules\seneca-kafka-transport\node_module
s\kafkaesque\lib\api.js:246:17)
at Socket.EventEmitter.emit (events.js:95:17)
at Socket. (stream_readable.js:746:14)
at Socket.EventEmitter.emit (events.js:92:17)
at emitReadable (_stream_readable.js:408:10)
at emitReadable (_stream_readable.js:404:5)
at readableAddChunk (_stream_readable.js:165:9)

thanks,
Roman

Could you please move this project to senecajs? @rjrodger @mcdonnelldean

I am interested to be maintainer on this plugin.

Evaluating seneca-kafka-transport by running through the examples in the repo. We keep hitting the error below. Tried bumping to the latest version of seneca to no avail. It appears seneca-tranport is failing based on the action definition within the kafka transport.

seneca.add({role:'transport',hook:'listen',type:'queue'}, hookListenQueue);
seneca.add({role:'transport',hook:'client',type:'queue'}, hookClientQueue);

This is the line that is responding.
https://github.com/rjrodger/seneca-transport/blob/master/transport.js#L157

Is there a workaround for this? Any proposed fixes? Willing to help out if so.

steps

1. clone repo
2. step through examples of creating request/response topics
3. set config
4. node server.js

env

• node - 0.10.38
• kafka - 0.8.2.1
• zookeeper - 3.4.6_1

Seneca Fatal Error

Message: Seneca/0.5.21/3yg7c3tq7yj4/1437161526709/-: plugin-needed: [ 'plugin-needed', { name: 'seneca-beanstalkd-transport' } ]

Code: transport_listen

Stack:
at Seneca.fail (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/lib/seneca.js:1882:15)
at handle_legacy_types (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/node_modules/seneca-transport/transport.js:138:19)
at Seneca.cmd_listen (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/node_modules/seneca-transport/transport.js:107:9)
at Object.execspec.fn (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/lib/seneca.js:1442:24)
at Object._onImmediate (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/lib/executor.js:93:14)
at processImmediate as _immediateCallback

Instance: Seneca/0.5.21/3yg7c3tq7yj4/1437161526709/-

When: 2015-07-17T19:32:07.092Z

Log: [sys,seneca,0.5.21,3yg7c3tq7yj4/1437161526709/-,transport_listen,Seneca/0.5.21/3yg7c3tq7yj4/1437161526709/-: plugin-needed: [ 'plugin-needed', { name: 'seneca-beanstalkd-transport' } ],[{type=queue,msgprefix=seneca_,callmax=111111,msgidlen=12}]]

Node: { http_parser: '1.0', node: '0.10.38', v8: '3.14.5.9', ares: '1.9.0-DEV', uv: '0.10.36', zlib: '1.2.8', modules: '11', openssl: '1.0.1m' }