1回答
我有像下面这样的代码从Kafka中读取并保存到Elasticsearch，我正在使用spark streaming： jssc.start();
我的问题是，我需要根据主题的名称使"events/redi
浏览 5提问于2018-02-04得票数 0
回答已采纳
我目前正在使用Kadeck社区，有时在docker上使用命令来查看保存在kafka上的消息，但现在我正在测试事务语义，我只想查看提交的消息。我很难做到这一点。任何人都知道如何只查看提交的消息，即使使用其他第三方应用程序，如Kadeck。谢谢!
浏览 0提问于2020-02-18得票数 0
我打算使用Spring boot和webSocket以及Kafka实现一个聊天室，但是我需要知道Kafka是否提供了异步消息传递服务
浏览 2提问于2019-07-02得票数 0
以下是我为kafka生产者编写的python代码，我不确定这些消息是否可以发布到Kafka代理。因为消费者端没有收到任何消息。当我使用生产者控制台命令对其进行测试时，我的Consumer python程序运行良好。from __future__ import print_function
from pyspark import SparkContext
from kafka import= KafkaClient("l
浏览 6提问于2016-09-13得票数 0
回答已采纳
3回答
我们有一个消息调度器，它在将消息属性放到Kafka主题队列中之前，会根据消息属性生成一个散列键。在线搜索模仿Kafka主题队列的工具并没有帮助，我担心我可能想错了。最终，无论用于模拟Kafka队列的是什么，都应该以与本地集群相同的方式工作-即，为<e
浏览 1提问于2016-10-31得票数 10
回答已采纳
蜘蛛可以非常快地完成爬行，因为redis中的队列保持在一个非常低的数字，大多数时间少于10个。但demo.incoming中的消息数量每秒都在堆积。这是我用来查看Kafka中demo.incoming主题消息数的命令--broker-list localhost1 | awk -F ":" '
浏览 1提问于2019-07-07得票数 1
卡夫卡是新来的。这个处理0.8。
我看到有查询分区信息、主题等的方法，但是我看不出如何动态地创建一个主题。
浏览 4提问于2015-12-17得票数 8
回答已采纳
1回答
我们可以为kafka主题指定自定义分割器。因此，kafka生产者可以根据特定的自定义算法将消息确定地发送到特定的分区。
现在的问题是，当我增加分区数量时，kafka将如何在新分区之间重新分配现有消息？或者Kafka不会将消息分发到新分区？有可能触发这种重新分配吗？如果是这样，那么kafka将如何了解自定义分区程序，因为这段代码驻
浏览 6提问于2020-09-15得票数 1
我正在尝试将Flume与Kafka集成，我想将本地计算机上的一个文件传递给Flume，然后再传递给Kafka。我想在Kafka Consumer中查看我的文件内容。下面是我在Flume中的配置文件： #a1.sinks.k1.type = logger
a1.sinks.
浏览 0提问于2015-11-04得票数 1
在Kafka中，一个消费者可以订阅的主题的最大限制是什么。我在任何地方都找不到这个记录的值。
如果消费者订阅了500000个或更多的主题，性能是否会下降。
浏览 6提问于2017-09-19得票数 5
2回答
所以他们中的一个会得到问题，然后做一些事情，然后改变这个问题的状态。其他可能涉及这一问题的应用程序应该获得新的信息。这种情况一直持续到问题达到最终结束状态为止。问题在于必须映射问题，因为这些应用程序并不都支持相同的数据格式。
谢谢你的建议
浏览 2提问于2017-10-11得票数 1
回答已采纳
我是kafka社区的新手，我面临着一个具有挑战性的问题。我有两个应用程序，它们通过Rest webservice相互通信，主体是一个json消息。我如何使用kafka作为这两个应用程序之间的中间件，而对应用程序的影响很小或为零？ 这是我的原样场景： ? 我的未来场景： ? 我考虑过使用STM或一些拦截器来转换头部和正文。{
"first name" : "
浏览 35提问于2019-01-25得票数 2
回答已采纳
2回答
我想使用一个单独的生成器将JSON对象编写到多个主题。 kafka.setDefaultTopic(topic);
kafk
浏览 7提问于2017-09-06得票数 3
回答已采纳
我使用的是Kafka框架提供的默认server.properties/zookeeper.properties文件。module.exports = { kafka_server: 'localhost:9092',nodejs-producer.jscons
浏览 14提问于2021-09-14得票数 0
在我们的大数据时代，您的IT基础架构可能会受到各种来源数据涌入的影响。最重要的是，客户要求“实时”查看他们的数据，没有任何延迟时间，因此您的服务器需要快速处理和显示数据。Kafka是一个分布式流媒体平台，使公司能够创建实时数据源。Uber，Twitter，Airbnb，Yelp以及今天财富500强公司中超过30％的公司都在使用它。例如，通过集成各种数据，如喜欢，页面点击，搜索，订单，购物车和库存，Kafka可以帮助实时将数据提供给预测
浏览 7199提问于2018-09-14
1回答
我在Bluemix上有一个Message实例，并且能够在它上生成/使用消息。我正在寻找一种快速，合理的方式浏览主题/消息，看看发生了什么。类似于的东西。我在本地安装了kafka-topics-ui，但无法将它连接到消息中心。我在kafka-rest-url配置文件(env.js)中使用了来自kafka-topics-ui凭据的kafka-topics-ui值，但无法确定<
浏览 5提问于2017-08-04得票数 3
回答已采纳
我必须发布来自kafka主题的消息到lambda来处理它们并使用springboot应用程序存储在数据库中，我做了一些研究并发现了一些可以使用kafka public Function<KStream<String, String>, KStream<String, String>> process(){}的消息，但我不确定这是否只用于将所消耗的消息发布到另一个kafka<
浏览 5提问于2022-08-11得票数 -2
我需要向一个主题发布特定的消息，将另一组消息发布到另一个主题，我目前正在使用Spring集成(Spring integration for Kafka )将消息发布到一个主题，但我正在寻找如何根据情况向不同的主题发布消息的示例我使用int-kafka:producer-configuration标记来创建上下文谢谢你的工
浏览 1提问于2018-02-05得票数 0
我们使用Kafka来存储由集群中的节点生成的消息，并分发到集群中的所有节点，我让它主要使用akka-streams，但有几个问题我必须解决。这是有一些限制的。首先，消息必须由集群中的每个节点使用，但只由一个节点生成。我知道我可以为每个节点分配一个组id，这可能是它的节点ID，这意味着每个节点都会收到消息。已经排序好了。但这里有一些问题。数据是非常短暂和相当大的(仅低于一兆字节)，不能进一步压缩或分解
浏览 0提问于2017-12-06得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
