kafka实时例子 kafka实时例子|ApacheKafka教程

到现在为止，我们学习了如何在Apache Kafka上读写数据。在本节中，我们将学习将真实数据源放入Kafka。
【kafka实时例子】在这里，我们将讨论一个实时应用程序，即Twitter。用户将了解有关创建Twitter生产者以及如何产生Tweet的知识。
Twitter是一项社交网络服务，允许用户进行交互并发布消息。这些消息称为推文。 Twitter用户通过发帖和通过推文对不同帖子进行评论来进行交互。
要处理Twitter，我们需要获取Twitter应用程序的凭据。可以通过创建Twitter开发人员帐户来完成。这样做，请按照以下步骤操作：
步骤1：创建一个Twitter帐户（如果该帐户不存在）。
步骤2：在网络浏览器中打开“ developer.twitter.com”，如下所示：

文章图片
单击“应用”选项。
步骤3：将打开一个新页面。点击“申请开发者帐户”

文章图片
步骤4：将打开一个新页面，询问预定用途，例如“如何使用Twitter数据？”，依此类推。快照如下所示：

文章图片
提供适当的答案后，单击“下一步”。
步骤5：下一部分是“评论”部分。在这里，用户说明将由Twitter查看，如下所示：

文章图片
如果twitter找到合适的答案，将启用“看起来不错”选项。然后，移至下一部分。
第6步：最后，将要求用户查看并接受开发者协议。通过单击复选框接受协议。通过单击“提交申请”提交申请。

文章图片
步骤7：成功完成后，将打开一个电子邮件确认页面。使用提供的电子邮件ID进行确认，然后继续进行操作。
步骤8：确认后，将打开一个新网页。点击“创建应用”，如下所示：

文章图片
步骤9：提供应用程序详细信息，如以下快照所示：

文章图片
步骤10：在提供应用程序详细信息后，点击“创建”选项。对话框将打开“查看我们的开发人员条款”。点击“创建”选项。快照如下所示：

文章图片
最后，将通过以下方式创建该应用程序：

文章图片
注意：将在何时创建应用程序。它将生成密钥和令牌。不要泄露它们，因为它们是机密或敏感信息。如果这样做，用户可以出于安全目的对其进行再生。步骤11：创建应用后，我们需要在’ pom.xml’ 文件中添加twitter依赖项。为此，请在网络浏览器上打开“ github twitter java”。快照如下所示：