我想把我的谷歌浏览器历史发给Kafka。
我的基本想法是使用位于
c:/users/master/appdata/local/google/chrome/user-data/default/history(用户数据/默认值/历史记录)
为此,我想使用kafka文件源连接器。
但是在运行kakfa源代码连接器之后,如何发送新添加的chrome历史日志呢?
有没有办法跟踪源文件的更改以便kafka代理可以确认?
我想把我的谷歌浏览器历史发给Kafka。
我的基本想法是使用位于
c:/users/master/appdata/local/google/chrome/user-data/default/history(用户数据/默认值/历史记录)
为此,我想使用kafka文件源连接器。
但是在运行kakfa源代码连接器之后,如何发送新添加的chrome历史日志呢?
有没有办法跟踪源文件的更改以便kafka代理可以确认?
1条答案
按热度按时间pcww981p1#
实际上,您可以使用filestreamsourceconnector来实现这一点。你不需要做任何其他事情。
一旦你开始
FileStreamSourceConnector
,它将挂接到指定的文件。因此,每当新数据附加到文件中时,连接器将自动生成主题。从我上面分享的链接:
此连接器将只读取一个文件,并将该文件中的数据发送给kafka。然后它将只监视文件的附加更新。对已发送给Kafka的文件行的任何修改都不会重新处理。
这可能会帮助您:使用connect读取文件数据