Skip to content

Fix incorrect method name from !1093.

Cody Messick requested to merge cody.messick/gwcelery:consumer_bug into main

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