samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jason Erickson <>
Subject Samza task not receiving on one partition
Date Mon, 25 Apr 2016 21:33:21 GMT
I have a puzzling issue with one of my samza tasks. It works correctly
except for messages on one partition. I have 9 partitions on the topic. If
I send 1000 messages, I only receive about 890 of them. I have checked with
kafka-console-consumer with partition keys that I know don’t get processed
by my samza job and the console consumer DOES see the message, so I know
it’s getting written to the topic and that at least a vanilla consumer can
see it just fine.

I’m happy to share whatever interesting configuration information would
help narrow this down, but right now, I’m a bit mystified about what I
would even share.

 I’m running

* samza-kafka_2.10 version 0.9.1

* kafka_2.10 version on the client

* kafka broker

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message