学习 该项目是的的配套存储库。 Kafka Connect源GitHub 该连接器允许您使用GitHub Api获取一系列问题并从GitHub存储库中提取请求: : 根据updated_at字段拉出问题,这意味着对问题或拉取请求的任何更新将出现在流中。 连接器写的主题很好地演示了日志压缩。 这也是自动化GitHub工作流程的一种有趣方式。 最终,它旨在成为一个教育性的示例,以演示如何编写比Kafka中提供的FileStreamSourceConnector更为简单的源连接器。 贡献 该连接器并不完美,可以改进,请随时提交您认为有用的任何PR。 组态 name=GitHubSourceConnectorDemo tasks.max=1 connector.class=com.simplesteph.kafka.GitHubSourceConnector topic=github-issues github.owner=kubernetes github.repo=kubernetes since.timestamp=2017-01-01T00:00:00Z # I heavi