2.2.2.1 Kafka

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