ReEnqueueMessage error occurs reason

[SarcoZ]

private void ReEnqueueMessage(ProduceMessage message)
{
if (message.ExpirationDate < DateTime.UtcNow)
{
OnMessageExpired(message);
return;
}

        message.Partition = Partitions.None; // so that round robined msgs are re robined
        if (Post(message))
        {
            MessageReEnqueued(message.Topic);
        }
        else
        {
            _cluster.Logger.LogWarning(string.Format(
                "[Producer] Failed to reenqueue message, discarding message for topic '{0}'", message.Topic));
            OnMessageDiscarded(message);
        }
    }

when send more message,such as 1000000 messages,error occurrs in this function,the reason is?

[ychuzevi]

Which error do you have? You mean the warning logged before discarding messages because they cannot be sent?