# Kafka payload errors

**URL:** <https://forum.dimagi.com/t/kafka-payload-errors/3257>\
**Category:** Users\
**Created:** [February 7, 2017, 5:55am UTC](https://forum.dimagi.com/t/kafka-payload-errors/3257 "2017-02-07T05:55:16Z")\
**Posts on this page:** 1\
**Page:** 1

<div class="post-metadata">

**Author:** ![czue](https://dimagi.b-cdn.net/user_avatar/forum.dimagi.com/czue/32/493_2.png) [@czue](https://forum.dimagi.com/u/czue)\
**Post date:** [February 7, 2017, 5:55am UTC](https://forum.dimagi.com/t/kafka-payload-errors/3257/1 "2017-02-07T05:55:16Z")

</div>

Hey,

For any issues related to hosting your own CommCare HQ instance please use  
[commcare-developers@googlegroups.com](mailto:commcare-developers@googlegroups.com).

thanks,  
Cory

> **···**
>
> On Fri, Feb 3, 2017 at 6:25 PM, wrote:
> 
> > Hi,
> > 
> > I get this error for each and every request sent from mobile to server.  
> > Error stack trace is:  
> > Message: Problem sending change to kafka {'domain': u't1',  
> > 'document\_subtype': u'[http://openrosa.org/formdesigner/1AA7D7F1-D70C-](http://openrosa.org/formdesigner/1AA7D7F1-D70C-)  
> > 430B-9D67-8B43A6705B3C', 'data\_source\_name': u'form-sql',  
> > 'data\_source\_type': u'form-sql', 'is\_deletion': False, 'document\_type':  
> > u'XFormDuplicate', 'document\_id': u'32cabb31-a227-4ced-93c5-02088b1f2a58',  
> > 'document\_rev': None}: (\<class 'kafka.common.FailedPayloadsError'\>)  
> > web\_1 | Value: None  
> > web\_1 | Traceback:  
> > web\_1 | File "/usr/local/lib/python2.7/threading.py", line  
> > 774, in \_\_bootstrap  
> > web\_1 | self.\_\_bootstrap\_inner()  
> > web\_1 | File "/usr/local/lib/python2.7/threading.py", line  
> > 801, in \_\_bootstrap\_inner  
> > web\_1 | self.run()  
> > web\_1 | File "/usr/local/lib/python2.7/threading.py", line  
> > 754, in run  
> > web\_1 | self.\_\_target(\*self.\_\_args, \*\*self.\_\_kwargs)  
> > web\_1 | File "/usr/local/lib/python2.7/SocketServer.py",  
> > line 596, in process\_request\_thread  
> > web\_1 | self.finish\_request(request, client\_address)  
> > web\_1 | File "/usr/local/lib/python2.7/SocketServer.py",  
> > line 331, in finish\_request  
> > web\_1 | self.RequestHandlerClass(request, client\_address,  
> > self)  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/django/core/servers/basehttp.py", line 102, in **init**  
> > web\_1 | super(WSGIRequestHandler, self). **init** (\*args,  
> > \*\*kwargs)  
> > web\_1 | File "/usr/local/lib/python2.7/SocketServer.py",  
> > line 652, in **init**  
> > web\_1 | self.handle()  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/django/core/servers/basehttp.py", line 182, in handle  
> > web\_1 | handler.run(self.server.get\_app())  
> > web\_1 | File "/usr/local/lib/python2.7/wsgiref/handlers.py",  
> > line 85, in run  
> > web\_1 | self.result = application(self.environ,  
> > self.start\_response)  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/django/contrib/staticfiles/handlers.py", line 63, in **call**  
> > web\_1 | return self.application(environ, start\_response)  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/ws4redis/django\_runserver.py", line 89, in application  
> > web\_1 | return \_django\_app(environ, start\_response)  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/django/core/handlers/wsgi.py", line 189, in **call**  
> > web\_1 | response = self.get\_response(request)  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/django/core/handlers/base.py", line 132, in get\_response  
> > web\_1 | response = wrapped\_callback(request,  
> > \*callback\_args, \*\*callback\_kwargs)  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/django/views/decorators/csrf.py", line 58, in wrapped\_view  
> > web\_1 | return view\_func(\*args, \*\*kwargs)  
> > web\_1 | File "/vendor/lib/python2.7/site-  
> > packages/django/views/decorators/http.py", line 45, in inner  
> > web\_1 | return func(request, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/domain/decorators.py",  
> > line 398, in wrapped\_view  
> > web\_1 | return view\_func(request, domain, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/receiverwrapper/views.py",  
> > line 248, in secure\_post  
> > web\_1 | return decorated\_view(request, domain,  
> > app\_id=app\_id)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/ota/utils.py",  
> > line 192, in \_inner  
> > web\_1 | response = f(request, domain, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/domain/decorators.py",  
> > line 182, in safe\_fn  
> > web\_1 | return \_inner(request, domain, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/domain/decorators.py",  
> > line 307, in \_inner  
> > web\_1 | return fn(request, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/domain/auth.py",  
> > line 80, in wrapper  
> > web\_1 | return view(request, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/domain/decorators.py",  
> > line 240, in \_inner  
> > web\_1 | return fn(request, domain, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/domain/decorators.py",  
> > line 178, in \_inner  
> > web\_1 | return fn(request, domain, \*args, \*\*kwargs)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/receiverwrapper/views.py",  
> > line 226, in _secure\_post\_basic  
> > web\_1 | authenticated=True,  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/receiverwrapper/views.py",  
> > line 94, in process\_form  
> > web\_1 | response, instance, cases = submission\_post.run()  
> > web\_1 | File "/mnt/commcare-hq/corehq/form\_processor/submission\_post.py",  
> > line 154, in run  
> > web\_1 | self.interface.save\_processed\_models([instance])  
> > web\_1 | File "/mnt/commcare-hq/corehq/form  
> > processor/interfaces/processor.py", line 126, in save\_processed\_models  
> > web\_1 | stock\_result=stock\_result,  
> > web\_1 | File "/mnt/commcare-hq/corehq/form_  
> > processor/backends/sql/processor.py", line 89, in save\_processed\_models  
> > web\_1 | cls._publish\_changes(processed\_forms, cases,  
> > stock\_result)  
> > web\_1 | File "/mnt/commcare-hq/corehq/form_  
> > processor/backends/sql/processor.py", line 94, in _publish\_changes  
> > web\_1 | publish\_form\_saved(processed\_forms.submitted)  
> > web\_1 | File "/mnt/commcare-hq/corehq/form_  
> > processor/change\_publishers.py", line 23, in publish\_form\_saved  
> > web\_1 | producer.send\_change(topics.FORM\_SQL,  
> > change\_meta\_from\_sql\_form(form))  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/change\_feed/producer.py",  
> > line 76, in send\_change  
> > web\_1 | send\_to\_kafka(self.producer, topic, change\_meta)  
> > web\_1 | File "/mnt/commcare-hq/corehq/apps/change\_feed/producer.py",  
> > line 41, in send\_to\_kafka  
> > web\_1 | change\_meta.to\_json(), e, type(e)
> > 
> > May I know why is this message a constant for any type of form, for any  
> > number of question. I am unable to post any form data.
> > 
> > Could anyone help me.
> > 
> > --  
> > You received this message because you are subscribed to the Google Groups  
> > "commcare-users" group.  
> > To unsubscribe from this group and stop receiving emails from it, send an  
> > email to [commcare-users+unsubscribe@googlegroups.com](mailto:commcare-users+unsubscribe@googlegroups.com).  
> > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout).
