kafka生产者正在发送帧，我想使用这些帧，每当使用这些帧时，我都希望在html上显示该帧。我已经看到我必须使用nodejs让消费者使用数据，但是当我收到数据时，我如何向客户端或前端调用或更新数据。我们需要使用某种websocket之类的东西吗？请帮助我在js中的kafka客户端的前端。
浏览 19提问于2020-11-05得票数 0
回答已采纳
我以为所有的Java依赖都是和pip install apache-flink一起安装的 以上错误发生在该行上： kafka_consumer = FlinkKafkaConsumer( deserialization_schema=deserialization_schema, 'bootstrap.servers': KAFKA_BOOTSTRAP_SERVERS}) 根据错误，我是否需要在pyflink环
浏览 252提问于2021-09-26得票数 0
我在我的Kafka集群中有一个简单的观察(Kafka 0.11.0.0)。
根据jmx的信息，__consumer_offsets主题经常装载的消息是所有其他主题中所有消息之和的10倍。我如何检查Kafka经纪人在做什么并自己产生这样的负载？
浏览 3提问于2017-11-10得票数 3
回答已采纳
我正在尝试使用kafka- avro -console-consumer以log4j格式打印关于kafka主题的avro消息。现在，如果我运行常规的kafka-console-consumer，使用以下命令：[2018-07-17 19:09:40,514]
浏览 0提问于2018-07-18得票数 1
我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
我正在尝试将单独的Serde放在我的每个消费者身上，而不是所有消费者。例如，这会将Avro反序列化程序添加到我的应用程序中的所有使用者。我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializerspring.cloud.stream.kafka.binde
浏览 13提问于2020-10-28得票数 0
回答已采纳
6回答
我正在使用Java编写一个kafka消费者。我想保持消息的实时，所以如果有太多的消息等待消费，比如1000或更多，我应该放弃未消费的消息，从最后一个偏移量开始消费。对于这个问题，我尝试比较上一个提交的偏移量和一个主题的结束偏移量(只有1个分区)，如果这两个偏移量之间的差异大于某个值，我会将该主题的最后一个提交的偏移量设置为下一个偏移量，这样我就可以丢弃那些冗余的消息现在我的问题是如何获得一个主题<e
浏览 75提问于2016-07-18得票数 38
回答已采纳
1回答
我有一个要求，从多个卡夫卡topicsAvro的流媒体，并把他们在格林梅利与小修改的有效载荷。
Kaka主题定义为配置文件中的列表，每个Kafka主题都有一个目标表。我正在寻找一个单一的星火结构应用程序和一个更新的配置文件，以听取新的主题或停止。听这个话题。
浏览 2提问于2020-11-06得票数 1
回答已采纳
有没有办法使用javascript解码主题__consumer_offsets中的数据？现在我有一些类似的东西： if(data.value) { }并打印像data.value这样的东西:data.value-78bfd5c4-2a48-4573-ae6b-5f5957
浏览 4提问于2018-02-28得票数 1
回答已采纳
我的kafka版本是2.4.1，我用格式化程序输出主题'__consumer_offsets‘消息，控制台没有输出任何东西，而不使用格式化程序可以输出消息，下面是我的shell命令
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic __consumer_offsets --formatter 'kafka</
浏览 0提问于2021-03-04得票数 1
回答已采纳
当使用卡夫卡控制台消费者或kt(卡夫卡的GoLang工具)从卡夫卡主题消费时，我得到的是无效字符。\u0000\ufffd?尽管Kafka实际上可以将适当的数据汇到数据库中。
浏览 0提问于2019-02-04得票数 0
回答已采纳
我有一个群体中的多个消费者。卡夫卡如何识别每个消费者是不同的，并将其映射到分区。
或者-用于识别组中的消费者的唯一键是什么？
浏览 3提问于2017-10-18得票数 5
回答已采纳
1回答
我正在研究集装箱化应用程序，其中前端应用程序调用HTTP请求到API网关。API网关收到的请求数据通过Kafka转发给Micro服务。但我必须将响应作为响应发送回API网关，并返回到前端应用程序。请问如何通过Kafka实现API网关和micron服务的同步请求和响应？ 我尝试过Producer和Consumer，这就像Fire一样，忘记了我无法响应请求的地方。 提前谢谢。Arun using Confluent.Kafka;
Pr
浏览 127提问于2020-05-02得票数 1
我有一个Streaming应用程序，它从Kafka主题中读取数据并将其放在HDFS上。我希望应用程序存储抵消读到__consumer_offsets主题的消息，以便在应用程序失败时开始阅读。这个应用程序运行良好(我可以看到HDFS上的数据)，但我看不到它对__consumer_offsets的提交。" -> "true",
浏览 0提问于2018-11-08得票数 0
1回答
使用Java Kafka Streams API。我想为我正在消费的主题选择一个新的键。新密钥将是不同类型的。当我使用控制台消费者使用带有新键的主题时，我只能看到值。.to("foobartopic",
Produced.with(Serdes.Integer(),bookValueIntSerde)); 消费"foobartopic“的结果预期的结果是相同的，但有一个非空键。
浏览 11提问于2019-02-05得票数 1
回答已采纳
我创建了一个带有JSON格式记录的Kafka主题。./kafka-console-consumer.sh --new-consumer \ --from-beginning \ --consumer.config &#x
浏览 5提问于2017-05-24得票数 1
回答已采纳
我们正在为我们的日志处理设置kafka (v0.8)和zookeeper。我正在尝试使用在中定义的API，尝试使用Metadata API来获取所有主题和分区的信息。文档说，元数据请求可以被定向到集群中的任何代理。我不清楚如何定向请求(或者如何确定请求可以定向到的代理之一)。我正在编写的代码是用Java编写的，用于设置一个全面的监控系统。有没有人能提供一个示例代码，用于使用那些用于监视且与消费者或生产者无关的API？我见过Scala中
浏览 2提问于2015-01-29得票数 2
1回答
拥有： |- consume_script.js需要 index.html这样做： <head> <body> </body>问题：
consume_scri
浏览 3提问于2017-07-27得票数 0
我想做卡夫卡主题的负载/性能测试使用J量仪。场景:对Kafka的请求读取响应从Kafka请求到Kafka读取从其他MQ请求到其他MQ的响应来自Kafka的读响应
有人能帮助我们如何实现这一点，任何设置或其他什么吗？
浏览 2提问于2019-09-05得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
