我想用kafka实现一个队列机制。但如果可以从为任何主题创建的队列中窥视数据而不进入其中，则找不到任何位置。我想从队列中读取数据，并根据不同的条件删除现有消息或将另一个消息添加到此队列中。另外，是否可以从不同的机器使用一个kafka服务器。我参考了tutorialspoint了解更多信息。提前谢谢。任何线索都将不胜感激。
1zmg4dgp1#
请记住，kakfa可以为每个主题扩展多个分区，并且不能保证分区之间的排序。所以，如果你想要严格的命令，就不要使用Kafka。在使用者组中，如果希望每个主题有n个使用者，则需要至少有n个分区。使用者不会删除消息，而是提交消息的偏移量。大多数客户机的默认配置是读取时自动提交偏移量。您可以随时在主题中重新插入消息。但您不能跳过一条消息而期望稍后处理它。您可以将任意多台计算机连接到kafka服务器。通常，您将多个服务器作为kafka集群，并通过复制实现容错。
1条答案
按热度按时间1zmg4dgp1#
请记住，kakfa可以为每个主题扩展多个分区，并且不能保证分区之间的排序。所以，如果你想要严格的命令，就不要使用Kafka。在使用者组中，如果希望每个主题有n个使用者，则需要至少有n个分区。
使用者不会删除消息，而是提交消息的偏移量。大多数客户机的默认配置是读取时自动提交偏移量。您可以随时在主题中重新插入消息。但您不能跳过一条消息而期望稍后处理它。
您可以将任意多台计算机连接到kafka服务器。通常，您将多个服务器作为kafka集群，并通过复制实现容错。