Kafka 缺点？
- 由于是批量发送，数据并非真正的实时；
- 对于mqtt协议不支持；
- 不支持物联网传感数据直接接入；
- 仅支持统一分区内消息有序，无法实现全局消息有序；
- 监控不完善，需要安装插件；
- 依赖zookeeper进行元数据管理；
-
本文向大家介绍Apache Kafka的缺陷相关面试题，主要包含被问及Apache Kafka的缺陷时的应答技巧和注意事项，需要的朋友参考一下 答：Kafka的局限性是： 没有完整的监控工具集 消息调整的问题 不支持通配符主题选择 速度问题
-
我在Kafka Streams拓扑工作，有时，在更改应用程序ID和/或clientId属性后，我在特定的kafka流上收到错误：“”。我已经在每个Kafka节点的server.properties中设置了属性，但似乎没有创建此流的主题。 这是我的Kafka Streams拓扑：
-
为了开始Kafka的项目，我在这里按照Databricks的指示行事： 结构化流媒体Kafka集成指南（Kafka broker版本0.10.0或更高版本） 代码： 我的Hadoop版本是2.6，Spark版本是2.3.0 带有的命令行是： 错误消息： Py4JJavaError：在elation.scala:33010调用ource.scala:94时发生错误：org.apache.spark.
-
我的Kafka消费者的代码是这样的 我已经意识到，这种消费者设置无法读取所有信息。我无法再现这一点，因为这是一个间歇性的问题。 当我使用 将最后 100 条消息与此消费者进行比较时，我发现我的消费者间歇性地随机错过了几条消息。我的消费者有什么问题？ 在python中使用消息的方法太多了。应该有一种最好只有一种明显的方法来做到这一点。
-
我正在尝试导出kafka连接指标。我的解决方案包括运行jmx导出器，并在endpoint处公开它们，然后可以使用Prometheus擦除。现在，我可以对我尝试过的所有指标都这样做，但对于一组指标，它不起作用。我对这组指标的导出配置如下 根据官方文档，这些指标的定义如下所示： 我想模式选择有问题，但我无法弄清楚是什么。请提供任何帮助或建议！！
-
我用的是阿帕奇·Kafka。我创建了一个war文件，其中生产者用Java编码，消费者用Scala编码。制作人正在从HTML页面获取数据。我可以看到，生产商发布的大部分数据都是关于消费者的，但有些数据缺失。 这是我的制片人代码 文件1 } 文件2 现在，我使用以下命令检查消费者的消息。 我是否缺少任何生产者配置？