这家伙太懒,什么都没留下
发送的结果是一个RecordMetadata,它指定了消息发送的分区,分配的offset和消息的时间戳。如果topic使用的是CreateTime,则使用用户提供的时间戳或发送的时间(如果用户没有指定指定消息的时间戳)如果topic使用的是LogAppendTime,则追加消息时,时间戳是broker的本地时间。参见 timestamp - topic/partition中记录的时间戳。
博主你好,java想获取kafka收到消息的那个时间戳,我是用kafkaTemplate发送的,用哪个API,或者哪个对象里面有这个时间戳?