Apache Kafka Consumer Connection -


i looking @ docs of apache kafka.

the consumer connects kafka using ip address/port of zookeepers.

is possible use ip address/port of broker?

yes, when using simple consumer api manage consumption directly brokers. see usage example here


-

Comments

Post a Comment

Popular posts from this blog

objective c - Deep Linking for iOS Apps which are not installed yet? -

i want use deep linking specific place in app using lib like: https://github.com/usebutton/ios-deeplink-sdk i know how make deep linking when app installed on device. how can deep link app not installed on device, i.e., link refers appstore , after installing app deep link token should present? you use uiapplications canopenurl method check if app exists. see example: -(void)openotherapp { uiapplication * myapplication = uiapplication.sharedapplication; nsstring * urlencodedstring = [@"somesortofaction" stringbyaddingpercentescapesusingencoding:nsutf8stringencoding]; nsstring * completepath = [@"otherappsurlscheme://" stringbyappendingstring:urlencodedstring]; nsurl * theurl = [nsurl urlwithstring:completepath]; if ([myapplication canopenurl:theurl]) { // app installed, launch [myapplication openurl:theurl]; } else { // app not installed open app store // replace appstore web ur...
Read more

Changing nested dictionary in VBA -

i ask question when solution came in 1 test. i'm posting anyway , answering, others can benefit. the question was: i run code below , runtime error 450 - wrong number of arguments or invalid property assignment dim data, tmpdict dictionary set data = new dictionary set tmpdict = new dictionary data.add 123, tmpdict set tmpdict = data.item(123) tmpdict.add "somekey", 100 data.item(123) = tmpdict the error occur in last line. code simplified focus on changing nested dictionary in existing item. how can succeed in this? the solution can achieved contracting last 3 lines in 1, using: data.item(123).add "somekey", 100 instead of: set tmpdict = data.item(123) tmpdict.add "somekey", 100 data.item(123) = tmpdict
Read more

javascript - SignalR sharing connection between 2 apps -

i have 2 projects in solution, 1 mvc app , second 1 simple windows forms app. i'm trying do, testing purposes, control content on mvc app through windows forms app. simplify further, have button on app, should, when clicked, update html on connected clients. mvc should manage client connections, , forms app should dedicated content administration. what did - mvc hub setup public class connectionhub : hub { public void update() { clients.all.updatesequence(" "); } } mvc startup setup: [assembly: owinstartup(typeof(web.startup))] namespace web { public class startup { public void configuration(iappbuilder app) { globalhost.dependencyresolver.usesqlserver( configurationmanager.connectionstrings["signalr"].connectionstring); app.mapsignalr(); } } } forms app - on button clicked event: private void button1_click(object sender, eventargs e) { var co...
Read more