-
Notifications
You must be signed in to change notification settings - Fork 387
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
KafkaActorSubscriber log statement not displaying exception #21
Comments
Thanks, @gvd! Indeed, the logging interface is a bit unfortunate, I'm fixing this to |
Maybe you could have an |
@adamw Underneath the subscriber is an Akka actor. Errors can be handled with custom behavior using DeathWatch. I'm checking how one can pass more details on exceptions with that. |
I might be wrong, but currently the underlying actor is not returned when building the stream, thus inhibiting the ability to supervise/register for deathwatch of that actor. |
There is some public API not mentioned in README. You can build your consumer like this: val consumerActor = reactiveKafka.consumerAsActor[T](...)
val consumer = ActorPublisher[String](consumerActor) and you have a working ActorRef which you can watch. I'm also trying to make it possible to supervise this actor, so that you can capture full exception when it crashes. Only then I'll fully close this issue. |
Fixed fully in #23 |
In https://github.com/softwaremill/reactive-kafka/blob/master/src/main/scala/com/softwaremill/react/kafka/KafkaActorSubscriber.scala on line 36 I see:
log.error("Stopping subscriber due to an error", ex)
Which does not display the exception message
The text was updated successfully, but these errors were encountered: