Skip to content
Snippets Groups Projects

Fix incorrect method name from !1093.

Merged Cody Messick requested to merge cody.messick/gwcelery:consumer_bug into main
All threads resolved!

Closes #678 (closed).

There was a thinko in !1093 (merged) where I accidentally called gwcelery.kafka.KafkaListener.get_payload_output instead of gwcelery.kafka.KafkaListener.get_payload_content. This function, set here, unpacks the contents of the Kafka message. This is needed because the avro and JSON serialized messages are packed slightly differently.

Edited by Cody Messick

Merge request reports

Loading
Loading

Activity

Filter activity
  • Approvals
  • Assignees & reviewers
  • Comments (from bots)
  • Comments (from users)
  • Commits & branches
  • Edits
  • Labels
  • Lock status
  • Mentions
  • Merge request status
  • Tracking
Please register or sign in to reply
Loading