Kafka直连方式存储MySQL

记得在以前写了一篇是MySQL基础使用的,此次就用MySQL来保存Direct方式的偏移量。 代码以下:mysql package kafka1 import kafka.common.TopicAndPartition import kafka.message.MessageAndMetadata import kafka.serializer.StringDecoder import org.
相关文章
相关标签/搜索