Kafka payload errors

Hey,

For any issues related to hosting your own CommCare HQ instance please use
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-
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.
For more options, visit https://groups.google.com/d/optout.