{"action":"opened","issue":{"url":"https://api.github.com/repos/spring-projects/spring-integration-kafka/issues/121","repository_url":"https://api.github.com/repos/spring-projects/spring-integration-kafka","labels_url":"https://api.github.com/repos/spring-projects/spring-integration-kafka/issues/121/labels{/name}","comments_url":"https://api.github.com/repos/spring-projects/spring-integration-kafka/issues/121/comments","events_url":"https://api.github.com/repos/spring-projects/spring-integration-kafka/issues/121/events","html_url":"https://github.com/spring-projects/spring-integration-kafka/issues/121","id":158252350,"number":121,"title":"KEY_SERIALIZER_CLASS_CONFIG & VALUE_SERIALIZER_CLASS_CONFIG","user":{"login":"dholtz","id":1517343,"avatar_url":"https://avatars.githubusercontent.com/u/1517343?v=3","gravatar_id":"","url":"https://api.github.com/users/dholtz","html_url":"https://github.com/dholtz","followers_url":"https://api.github.com/users/dholtz/followers","following_url":"https://api.github.com/users/dholtz/following{/other_user}","gists_url":"https://api.github.com/users/dholtz/gists{/gist_id}","starred_url":"https://api.github.com/users/dholtz/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/dholtz/subscriptions","organizations_url":"https://api.github.com/users/dholtz/orgs","repos_url":"https://api.github.com/users/dholtz/repos","events_url":"https://api.github.com/users/dholtz/events{/privacy}","received_events_url":"https://api.github.com/users/dholtz/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":0,"created_at":"2016-06-02T22:18:14Z","updated_at":"2016-06-02T22:18:14Z","closed_at":null,"body":"I apologize in advance if this is the wrong forum to ask this question, but I couldn't find much documentation around the matter.\r\n\r\nLet's say we generate some Avro classes from IDL or schema and want to use those objects as the things we will send to / receive from a Kafka topic.\r\n\r\n**The Kafka Producer Channel Adapter** section of this example:\r\n\r\nhttps://spring.io/blog/2016/04/11/spring-integration-kafka-support-2-0-0-m1-is-now-available\r\n\r\ngives some hint of how to wire this all together, but I still feel like I'm missing something.\r\n\r\nWhat should the values of <see subject line> be if we want to serialize an Avro object?\r\n\r\n`  @Bean\r\n  public ProducerFactory<String, byte[]> producerFactory() {\r\n    Map<String, Object> props = new HashMap<>();\r\n    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.brokerAddress);\r\n    props.put(ProducerConfig.RETRIES_CONFIG, 0);\r\n    props.put(ProducerConfig.BATCH_SIZE_CONFIG, 16384);\r\n    props.put(ProducerConfig.LINGER_MS_CONFIG, 1);\r\n    props.put(ProducerConfig.BUFFER_MEMORY_CONFIG, 33554432);\r\n    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);\r\n    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);\r\n    return new DefaultKafkaProducerFactory<>(props);\r\n  }`\r\n\r\nIn earlier versions this class existed:\r\n\r\n`org.springframework.integration.kafka.serializer.avro.AvroSpecificDatumBackedKafkaEncoder`\r\n\r\n\r\n"}}
{"actor":{"display_login":"dholtz"}}