Closed joestein closed 9 years ago
Hey @joestein I just published 0.0.9-0.8.2-beta-SNAPSHOT to oss.sonatype, off of https://github.com/sclasen/akka-kafka/tree/kafka-082-beta
Give it a whirl?
@sclasen works great, thanks!!!
@joestein any version compatibility issues to be aware of? Seems like the 082 client works fine with an 0811 server.
If no issues, I'll cut this as 0.0.9
Any chance we can get one compiled with 2.11 in the repo?
@5ilvers just updated the branch to do a cross build and published to oss.sonatype. let me know if that works for you.
@sclasen w00t!! so fast!! much appreciated! so far so good, I will report back if I see any problem.
I think you can close this :)
:+1:
commitOffsets needs () at the end now since we added an optional param to it
[ERROR] [10/31/2014 14:58:09.515] [default-akka.actor.default-dispatcher-5] [ActorSystem(default)] Uncaught error from thread [default-akka.actor.default-dispatcher-5] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled java.lang.NoSuchMethodError: kafka.consumer.ConsumerConnector.commitOffsets()V at com.sclasen.akka.kafka.BatchConnectorFSM$$anonfun$5.applyOrElse(BatchActors.scala:148) at com.sclasen.akka.kafka.BatchConnectorFSM$$anonfun$5.applyOrElse(BatchActors.scala:129) at com.sclasen.akka.kafka.BatchConnectorFSM$$anonfun$5.applyOrElse(BatchActors.scala:148) at com.sclasen.akka.kafka.BatchConnectorFSM$$anonfun$5.applyOrElse(BatchActors.scala:129) at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) at akka.actor.FSM$class.processEvent(FSM.scala:604) at com.sclasen.akka.kafka.BatchConnectorFSM.processEvent(BatchActors.scala:60) at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:598) at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:592) at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) at akka.actor.FSM$class.processEvent(FSM.scala:604) at com.sclasen.akka.kafka.BatchConnectorFSM.processEvent(BatchActors.scala:60) at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:598) at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:592) at akka.actor.Actor$class.aroundReceive(Actor.scala:465) at com.sclasen.akka.kafka.BatchConnectorFSM.aroundReceive(BatchActors.scala:60) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) at akka.actor.Actor$class.aroundReceive(Actor.scala:465) at com.sclasen.akka.kafka.BatchConnectorFSM.aroundReceive(BatchActors.scala:60) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) at akka.actor.ActorCell.invoke(ActorCell.scala:487) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) at akka.dispatch.Mailbox.run(Mailbox.scala:220) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) at akka.actor.ActorCell.invoke(ActorCell.scala:487) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) at akka.dispatch.Mailbox.run(Mailbox.scala:220) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)