Hi all, I have created a KIP to support negative timestamp: https://cwiki.apache.org/confluence/display/KAFKA/KIP-228+Negative+record+timestamp+support <https://cwiki.apache.org/confluence/display/KAFKA/KIP-228+Negative+record+timestamp+support>
Here are proposed changes: https://github.com/apache/kafka/compare/trunk...chuhlomin:trunk <https://github.com/apache/kafka/compare/trunk...chuhlomin:trunk> I'm pretty sure that not cases are covered, so comments and suggestions are welcome. Thank you, Konstantin
