Skip to content
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

Fix for issue #11 onNext IllegalStateException #13

Merged
merged 1 commit into from
Jun 16, 2015

Conversation

dbuschman7
Copy link

We ran into the same problem and fixed the KafkaActorPublisher to handle this scenario. We see this when topics are new and contain no messages yet.

@dbuschman7 dbuschman7 changed the title Fixe for issue #11 onNext IllegalStateException Fix for issue #11 onNext IllegalStateException Jun 14, 2015
@kciesielski
Copy link
Contributor

LGTM, thanks!

@dbuschman7
Copy link
Author

Looks like you did not merge the changes before you closed the PR

@kciesielski kciesielski reopened this Jun 16, 2015
kciesielski added a commit that referenced this pull request Jun 16, 2015
Fix for issue #11 onNext IllegalStateException
@kciesielski kciesielski merged commit dd105c7 into akka:master Jun 16, 2015
@kciesielski
Copy link
Contributor

Of course. Merged now :)

@iamthiago
Copy link

Is that already published on maven?

@kciesielski
Copy link
Contributor

@thiagoandrade6 Not yet. I want to review #14 and include it in the next release. It will be finished soon.

@iamthiago
Copy link

ok, Thanks... for now I'm using the following code.

implicit val materializer =
ActorFlowMaterializer(
ActorFlowMaterializerSettings(actorSystem)
.withInputBuffer(initialSize = 1024, maxSize = 1024))

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants