我想把我的谷歌浏览器历史发给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读取文件数据