Skip to content

Conversation

@sclasen
Copy link
Contributor

@sclasen sclasen commented May 16, 2014

check for errors when required acks > 0, refresh metadata on NotLeaderForPartition.

Im seeing quite a bit of these in my kafka logs, coming from poseidon producers, even for topics that have not been recently rebalanced.

WARN Produce request with correlation id 14 from client x.3865 on partition [<topic>,<partition>]failed due to Leader not local for partition [<topic>,<partition>] on broker X (kafka.server.KafkaApis)

hoping this patch will detect and fix that situation...

@sclasen
Copy link
Contributor Author

sclasen commented May 16, 2014

meh, still getting these.

@sclasen sclasen closed this May 16, 2014
@sclasen sclasen reopened this Jun 4, 2014
@sclasen
Copy link
Contributor Author

sclasen commented Jun 4, 2014

Think I was falling victim to #36, this is along the lines of how to check the produce repsonese for errors

@bpot
Copy link
Owner

bpot commented Jun 6, 2014

@sclasen thanks for tracking this down! I'm working on putting together an integration test that reproduces the issue.

@bpot bpot added this to the 0.0.5 milestone Jul 9, 2014
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.

2 participants