Github user karol-brejna-i commented on the issue:
https://github.com/apache/incubator-gearpump/pull/158
The good news is, Kafka "cluster" is up again (during integration tests).
The bad news, there is some error running Kafka example.
I found this in application logs:
```
INFO] [02/22/2017 08:20:08.282] [Executor@app2exec1] Executor received
restart tasks
[WARN] [02/22/2017 08:20:08.282] [ProducerConfig] The configuration
value.serializer = class
org.apache.kafka.common.serialization.ByteArraySerializer was supplied but
isn't a known config.
[WARN] [02/22/2017 08:20:08.283] [ProducerConfig] The configuration
key.serializer = class
org.apache.kafka.common.serialization.ByteArraySerializer was supplied but
isn't a known config.
[INFO] [02/22/2017 08:20:08.283] [KafkaSource] created checkpoint store for
[topic3,0]
[ERROR] [02/22/2017 08:20:08.283] [Executor@app2exec1] We got
java.lang.ArithmeticException from Some(TaskId(0,0)), we will treat it as
MessageLoss, so that the system will replay all lost message
java.lang.ArithmeticException: long overflow
at java.lang.Math.multiplyExact(Math.java:892)
at java.time.Instant.toEpochMilli(Instant.java:1232)
at
org.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource.open(AbstractKafkaSource.scala:94)
at
org.apache.gearpump.streaming.source.DataSourceTask.onStart(DataSourceTask.scala:71)
at
org.apache.gearpump.streaming.task.TaskWrapper.onStart(TaskWrapper.scala:96)
at
org.apache.gearpump.streaming.task.TaskActor.onStart(TaskActor.scala:107)
at
org.apache.gearpump.streaming.task.TaskActor.org$apache$gearpump$streaming$task$TaskActor$$onStartClock(TaskActor.scala:195)
at
org.apache.gearpump.streaming.task.TaskActor$$anonfun$waitForStartClock$1.applyOrElse(TaskActor.scala:212)
at akka.actor.Actor$class.aroundReceive(Actor.scala:496)
at
org.apache.gearpump.streaming.task.TaskActor.aroundReceive(TaskActor.scala:42)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
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)
[WARN] [02/22/2017 08:20:08.284] [OneForOneStrategy] long overflow
[INFO] [02/22/2017 08:20:08.285] [DataSourceTask@app2exec1TaskId(0,0)]
closing data source...
[INFO] [02/22/2017 08:20:08.283] [DataSinkTask@app2exec1TaskId(1,0)]
closing data sink...
```
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
