- [Fix] Few typos around DLQ and Pro DLQ Dispatch original metadata naming.
- [Fix] Narrow the components lookup to the appropriate scope (#1114)
Upgrade notes
- Replace
original-*references from DLQ dispatched metadata withoriginal_*
# DLQ topic consumption
def consume
messages.each do |broken_message|
topic = broken_message.metadata['original_topic'] # was original-topic
partition = broken_message.metadata['original_partition'] # was original-partition
offset = broken_message.metadata['original_offset'] # was original-offset
Rails.logger.error "This message is broken: #{topic}/#{partition}/#{offset}"
end
end