Kafka直連方式存儲MySQL

記得在以前寫了一篇是MySQL基礎使用的，此次就用MySQL來保存Direct方式的偏移量。 代碼以下：mysql package kafka1 import kafka.common.TopicAndPartition import kafka.message.MessageAndMetadata import kafka.serializer.StringDecoder import org.

>>阅读原文<<