spring xd - Direct binding deployment with Kafka as message bus -

-

i trying use direct binding on following stream.

stream create --definition "time | log" --name ticktock stream deploy ticktock --properties module.*.count=0

deployment fails exception on both admin , container node:

java.lang.illegalargumentexception: module count cannot 0     @ org.springframework.xd.dirt.integration.kafka.kafkamessagebus$kafkapropertiesaccessor.getnumberofkafkapartitionsforproducer(kafkamessagebus.java:799)     @ org.springframework.xd.dirt.integration.kafka.kafkamessagebus.bindproducer(kafkamessagebus.java:500)     @ org.springframework.xd.dirt.plugins.abstractmessagebusbinderplugin.bindmessageproducer(abstractmessagebusbinderplugin.java:287)     @ org.springframework.xd.dirt.plugins.abstractmessagebusbinderplugin.bindconsumerandproducers(abstractmessagebusbinderplugin.java:143)     @ org.springframework.xd.dirt.plugins.stream.streamplugin.postprocessmodule(streamplugin.java:73)     @ org.springframework.xd.dirt.module.moduledeployer.postprocessmodule(moduledeployer.java:238)     @ org.springframework.xd.dirt.module.moduledeployer.dodeploy(moduledeployer.java:218)     @ org.springframework.xd.dirt.module.moduledeployer.deploy(moduledeployer.java:200)     @ org.springframework.xd.dirt.server.container.deploymentlistener.deploymodule(deploymentlistener.java:365)     @ org.springframework.xd.dirt.server.container.deploymentlistener.deploystreammodule(deploymentlistener.java:334)     @ org.springframework.xd.dirt.server.container.deploymentlistener.onchildadded(deploymentlistener.java:181)     @ org.springframework.xd.dirt.server.container.deploymentlistener.childevent(deploymentlistener.java:149)     @ org.apache.curator.framework.recipes.cache.pathchildrencache$5.apply(pathchildrencache.java:509)     @ org.apache.curator.framework.recipes.cache.pathchildrencache$5.apply(pathchildrencache.java:503)     @ org.apache.curator.framework.listen.listenercontainer$1.run(listenercontainer.java:92)     @ com.google.common.util.concurrent.moreexecutors$samethreadexecutorservice.execute(moreexecutors.java:297)     @ org.apache.curator.framework.listen.listenercontainer.foreach(listenercontainer.java:83)     @ org.apache.curator.framework.recipes.cache.pathchildrencache.calllisteners(pathchildrencache.java:500)     @ org.apache.curator.framework.recipes.cache.eventoperation.invoke(eventoperation.java:35)     @ org.apache.curator.framework.recipes.cache.pathchildrencache$10.run(pathchildrencache.java:762)     @ java.util.concurrent.executors$runnableadapter.call(executors.java:471)     @ java.util.concurrent.futuretask.run(futuretask.java:262)     @ java.util.concurrent.executors$runnableadapter.call(executors.java:471)     @ java.util.concurrent.futuretask.run(futuretask.java:262)     @ java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor.java:1145)     @ java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:615)     @ java.lang.thread.run(thread.java:745)

i have spring-xd(1.2.0) cluster 1 admin , 2 container nodes using kafka message bus.

am doing wrong? or there problem direct binding , kafka message bus?

per the documentation, xd kafkamessagebus not support direct binding...

note: kafka message bus not support count=0 module deployments, , therefore, not support direct binding of modules. feature available in future release. in meantime, if direct communication between modules necessary kafka deployments, composite modules should used instead.


Comments

Post a Comment

Popular posts from this blog

c# - Store DBContext Log in other EF table -

-
i want store logs in db table (imported ef code). my code looks this: public pmcontext() : base("myentities") { configuration.proxycreationenabled = false; configuration.lazyloadingenabled = false; this.database.log = s => logstore(s); } private void logstore(string message) { tlog log = new tlog(); log.description = message; log.insertdate = datetime.now; logs.add(log); savechanges(); } public virtual dbset<tlog> logs { get; set; } i cannot use savechanges() (get error "sqlconnection not support parallel transactions") , if remove line nothing stored in db table. how can fix this? i think happens during savechanges call anywhere in app, because sql generated call logged, triggers nested savechanges call tries start own transaction. and there thing: savechanges call in logstore method trigger logging itself, you'd end starting infin...
Read more

c# - Display ASPX Popup control in RowDeleteing Event (ASPX Gridview) -

-
i have aspxgridview includes new , delete button. delete button includs gv_rowdeleting event. want show aspxpopupcontrol (id="pupconfirm"). want user have confirm password delete item. tried: protected void gv_rowdeleting(object sender, devexpress.web.data.aspxdatadeletingeventargs e) { pupconfirm.showonpageload = true; } but nothing happened. please me. !!! you can create template column javascript prompt confirmation. <itemtemplate> <asp:linkbutton id="btndelete" runat="server" text="delete" commandname="delete" onclientclick="javascript:if(!confirm('are sure want delete record?')){return false;}"> </asp:linkbutton> </itemtemplate>
Read more

Nuget pack csproj using nuspec -

-
i want create nuget package contains specified in nuspec file, still version csproj. in order use token have pack like: nuget pack myproj.csproj but when adds dependencies , creates unwanted folder in nuget package. nuspec file is: <?xml version="1.0" encoding="utf-8"?> <package xmlns="http://schemas.microsoft.com/packaging/2011/08/nuspec.xsd"> <metadata> <id>test</id> <version>$version$</version> <title>test</title> <authors>test</authors> <owners>test</owners> <requirelicenseacceptance>false</requirelicenseacceptance> <description>test</description> <summary>test</summary> <releasenotes>test</releasenotes> <copyright>test</copyright> </metadata> <files> <file src="bin\debug\*.dll" target="lib\net45" /> <file s...
Read more