Folks, In a recent commit I made regarding KAFKA-2121, there is an omitted API change which makes Serializer / Deserializer extending from Closeable, whose close() call could throw IOException by declaration. Hence now some scenario like:
--------------------- Serializer<T> keySerializer = ... Serializer<T> valueSerializer = ... KafkaProducer producer = new KafkaProducer(config, keySerializer, valueSerializer) // ... keySerializer.close() valueSerializer.close() --------------------- will need to capture IOException now. Want to bring this up for people's attention, and you opinion on whether we should revert this change? -- Guozhang
