{"action":"created","issue":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/66","repository_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka","labels_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/66/labels{/name}","comments_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/66/comments","events_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/66/events","html_url":"https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/66","id":186347975,"number":66,"title":"java.io.IOException: Packet len352518912 is out of range!","user":{"login":"altfatterz","id":1025546,"avatar_url":"https://avatars.githubusercontent.com/u/1025546?v=3","gravatar_id":"","url":"https://api.github.com/users/altfatterz","html_url":"https://github.com/altfatterz","followers_url":"https://api.github.com/users/altfatterz/followers","following_url":"https://api.github.com/users/altfatterz/following{/other_user}","gists_url":"https://api.github.com/users/altfatterz/gists{/gist_id}","starred_url":"https://api.github.com/users/altfatterz/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/altfatterz/subscriptions","organizations_url":"https://api.github.com/users/altfatterz/orgs","repos_url":"https://api.github.com/users/altfatterz/repos","events_url":"https://api.github.com/users/altfatterz/events{/privacy}","received_events_url":"https://api.github.com/users/altfatterz/received_events","type":"User","site_admin":false},"labels":[{"id":389237847,"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/labels/question","name":"question","color":"cc317c","default":true},{"id":466981936,"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/labels/ready","name":"ready","color":"5319e7","default":false}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":4,"created_at":"2016-10-31T17:37:23Z","updated_at":"2016-11-18T17:06:47Z","closed_at":null,"body":"Created a Kafka cluster on `https://aiven.io/kafka`\r\n\r\nMy configuration is:\r\n\r\n```\r\nspring:\r\n  cloud:\r\n    stream:\r\n      bindings:\r\n        input:\r\n          destination: test\r\n      kafka:\r\n        binder:\r\n          zk-nodes: <kafka-service>.<project>.aivencloud.com:20786\r\n```\r\n\r\nWith a demo app:\r\n\r\n```\r\n@SpringBootApplication\r\npublic class SinkApplication {\r\n    public static void main(String[] args) {\r\n        SpringApplication.run(SinkApplication.class, args);\r\n    }\r\n}\r\n\r\n@EnableBinding(Sink.class)\r\nclass LogSink {\r\n    private static Logger logger = LoggerFactory.getLogger(LogSink.class);\r\n\r\n    @ServiceActivator(inputChannel= Sink.INPUT)\r\n    public void loggerSink(Object payload) {\r\n        logger.info(\"Received: \" + payload);\r\n    }\r\n}\r\n\r\n```\r\nusing Spring Boot 1.4.1.RELEASE with Spring Cloud Camden.SR1\r\n\r\nfails with:\r\n\r\n```\r\n2016-10-31 18:30:12.179  INFO 72534 --- [           main] org.I0Itec.zkclient.ZkClient             : Waiting for keeper state SyncConnected\r\n2016-10-31 18:30:12.183  INFO 72534 --- [6.32.115:20786)] org.apache.zookeeper.ClientCnxn          : Opening socket connection to server 188.166.32.115/188.166.32.115:20786. Will not attempt to authenticate using SASL (unknown error)\r\n2016-10-31 18:30:12.214  INFO 72534 --- [6.32.115:20786)] org.apache.zookeeper.ClientCnxn          : Socket connection established to 188.166.32.115/188.166.32.115:20786, initiating session\r\n2016-10-31 18:30:12.283  WARN 72534 --- [6.32.115:20786)] org.apache.zookeeper.ClientCnxn          : Session 0x0 for server 188.166.32.115/188.166.32.115:20786, unexpected error, closing socket connection and attempting reconnect\r\n\r\njava.io.IOException: Packet len352518912 is out of range!\r\n\tat org.apache.zookeeper.ClientCnxnSocket.readLength(ClientCnxnSocket.java:112) ~[zookeeper-3.4.6.jar:3.4.6-1569965]\r\n\tat org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:79) ~[zookeeper-3.4.6.jar:3.4.6-1569965]\r\n\tat org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:366) ~[zookeeper-3.4.6.jar:3.4.6-1569965]\r\n\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) ~[zookeeper-3.4.6.jar:3.4.6-1569965]\r\n\r\n```\r\n\r\nDo you know what could be the reason?"},"comment":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/comments/261585347","html_url":"https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/66#issuecomment-261585347","issue_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/66","id":261585347,"user":{"login":"altfatterz","id":1025546,"avatar_url":"https://avatars.githubusercontent.com/u/1025546?v=3","gravatar_id":"","url":"https://api.github.com/users/altfatterz","html_url":"https://github.com/altfatterz","followers_url":"https://api.github.com/users/altfatterz/followers","following_url":"https://api.github.com/users/altfatterz/following{/other_user}","gists_url":"https://api.github.com/users/altfatterz/gists{/gist_id}","starred_url":"https://api.github.com/users/altfatterz/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/altfatterz/subscriptions","organizations_url":"https://api.github.com/users/altfatterz/orgs","repos_url":"https://api.github.com/users/altfatterz/repos","events_url":"https://api.github.com/users/altfatterz/events{/privacy}","received_events_url":"https://api.github.com/users/altfatterz/received_events","type":"User","site_admin":false},"created_at":"2016-11-18T17:06:47Z","updated_at":"2016-11-18T17:06:47Z","body":"I still have difficulties how to configure the ssl properties from the `ca.crt`, `client.crt` and `client.key` which I receive from aiven\r\n\r\n\r\n"}}
{"actor":{"display_login":"altfatterz"}}