THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
We iterate through each batch included in the write request, and the validation logic in sudo code for each record looks like the following:
| Code Block | ||||
|---|---|---|---|---|
| ||||
if message.timestamp <= broker.timestamp:
time_difference = broker.timestamp - message.timestamp
if time_difference <= log.message.timestamp.before.max.ms:
# Validation passed for timestamp before
// Proceed with further logic
else:
# Validation failed for timestamp before
return Error code 32 (INVALID_TIMESTAMP)
else if message.timestamp > broker.timestamp:
time_difference = message.timestamp - broker.timestamp
if time_difference <= log.message.timestamp.after.max.ms:
# Validation passed for timestamp after
// Proceed with further logic
else:
# Validation failed for timestamp after
return Error code 32 (INVALID_TIMESTAMP)
|
...