I'd like to introduce new feature for kafka client: Making org.apache.kafka.clients.Metadata#TOPIC_EXPIRY_MS configurable Here is KPI https://cwiki.apache.org/confluence/display/KAFKA/KIP-375%3A+Make+org.apache.kafka.clients.Metadata%23TOPIC_EXPIRY_MS+configurable
The problem is: if application sends records to some topic rarely then topic metadata gets expired and sending thread is blocked to wait topic metadata. Easy fix is to make TOPIC_EXPIRY_MS configurable. -- Pavel +7-903-258-5544 skype://pavel.moukhataev
