{"action":"created","issue":{"url":"https://api.github.com/repos/dpkp/kafka-python/issues/841","repository_url":"https://api.github.com/repos/dpkp/kafka-python","labels_url":"https://api.github.com/repos/dpkp/kafka-python/issues/841/labels{/name}","comments_url":"https://api.github.com/repos/dpkp/kafka-python/issues/841/comments","events_url":"https://api.github.com/repos/dpkp/kafka-python/issues/841/events","html_url":"https://github.com/dpkp/kafka-python/issues/841","id":181084078,"number":841,"title":"Silent MessageSizeTooLargeError","user":{"login":"lopuhin","id":424613,"avatar_url":"https://avatars.githubusercontent.com/u/424613?v=3","gravatar_id":"","url":"https://api.github.com/users/lopuhin","html_url":"https://github.com/lopuhin","followers_url":"https://api.github.com/users/lopuhin/followers","following_url":"https://api.github.com/users/lopuhin/following{/other_user}","gists_url":"https://api.github.com/users/lopuhin/gists{/gist_id}","starred_url":"https://api.github.com/users/lopuhin/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lopuhin/subscriptions","organizations_url":"https://api.github.com/users/lopuhin/orgs","repos_url":"https://api.github.com/users/lopuhin/repos","events_url":"https://api.github.com/users/lopuhin/events{/privacy}","received_events_url":"https://api.github.com/users/lopuhin/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-10-05T07:37:41Z","updated_at":"2016-10-05T15:39:03Z","closed_at":"2016-10-05T15:39:03Z","body":"When trying to send a message that is larger than maximum allowed size (``max_request_size`` argument of the ``KafkaProducer``), the message is silently dropped, and only debug logs show that is was dropped:\r\n```\r\nDEBUG:kafka.producer.sender:Starting Kafka producer I/O thread.\r\nDEBUG:kafka.producer.kafka:Kafka producer started\r\nDEBUG:kafka.producer.kafka:Exception occurred during message send: [Error 10] MessageSizeTooLargeError: The message is 13561908 bytes when serialized which is larger than the maximum request size you have configured with the max_request_size configuration\r\nDEBUG:kafka.producer.kafka:Flushing accumulated records in producer.\r\n```\r\nThe code that sends the message is just\r\n```\r\nproducer = KafkaProducer()\r\nproducer.send(topic, data)\r\nproducer.flush()\r\n```\r\nI would expect an exception to be thrown. I'm new to kafka so I'm not sure if my expectations are reasonable."},"comment":{"url":"https://api.github.com/repos/dpkp/kafka-python/issues/comments/251712199","html_url":"https://github.com/dpkp/kafka-python/issues/841#issuecomment-251712199","issue_url":"https://api.github.com/repos/dpkp/kafka-python/issues/841","id":251712199,"user":{"login":"lopuhin","id":424613,"avatar_url":"https://avatars.githubusercontent.com/u/424613?v=3","gravatar_id":"","url":"https://api.github.com/users/lopuhin","html_url":"https://github.com/lopuhin","followers_url":"https://api.github.com/users/lopuhin/followers","following_url":"https://api.github.com/users/lopuhin/following{/other_user}","gists_url":"https://api.github.com/users/lopuhin/gists{/gist_id}","starred_url":"https://api.github.com/users/lopuhin/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lopuhin/subscriptions","organizations_url":"https://api.github.com/users/lopuhin/orgs","repos_url":"https://api.github.com/users/lopuhin/repos","events_url":"https://api.github.com/users/lopuhin/events{/privacy}","received_events_url":"https://api.github.com/users/lopuhin/received_events","type":"User","site_admin":false},"created_at":"2016-10-05T15:39:03Z","updated_at":"2016-10-05T15:39:03Z","body":"Right, I didn't notice it, thanks for making it clear! The exception does happen with `get()`."}}
{"actor":{"display_login":"lopuhin"}}