Hi all, we noticed that when kafka broker configured with:
log.message.timestamp.type=LogAppendTime to timestamp incoming messages on its own and producer is configured to use any kind of compression. What we end up on the wire for consumer: - outer compressed envelope - LogAppendTime, by broker - inner messages - CreateTime, by producer Tried 0.10 and 0.10.2 version with producers in various languages. Is it by design? Broker just update timestamp of the outer compressed message and never look inside? Or is it bug in broker? Is there are guidelines for implementing clients, somebody can point to? Should client respect outer timestamp or inner? The main reason we got the question is different client implementations returns different timestamps in that case. Thanks all.