Kafka #

apache/kafka Github stars Language Last Tag Last commit

Kafka 是 linkedin 开源的 MQ 系统，主要特点是基于 Pull 的模式来处理消息消费，追求高吞吐量，一开始的目的就是用于日志收集和传输，0.8 开始支持复制，不支持事务，适合产生大量数据的互联网服务的数据收集业务。

序列化 #

StringSerializer 序列化，写入时使用 dest.kafka.1&key.serializer=org.apache.kafka.common.serialization.StringSerializer dest.kafka.1&value.serializer=org.apache.kafka.common.serialization.StringSerializer

StringDeserializer 反序列化，读出时使用 source.kafka.2&key.deserializer=org.apache.kafka.common.serialization.StringDeserializer source.kafka.2&value.deserializer=org.apache.kafka.common.serialization.StringDeserializer