Kafka直連方式存儲MySQL

記得在以前寫了一篇是MySQL基礎使用的,此次就用MySQL來保存Direct方式的偏移量。 代碼以下:mysql package kafka1 import kafka.common.TopicAndPartition import kafka.message.MessageAndMetadata import kafka.serializer.StringDecoder import org.
相關文章
相關標籤/搜索