Hi, all, I would like to start the vote for KIP-216.
Currently, IQ throws InvalidStateStoreException for any types of error. With this KIP, user can distinguish different types of error. KIP is here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-216%3A+IQ+should+throw+different+exceptions+for+different+errors Thanks --- Vito -- --- Vito