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.

Reply via email to