我正在尝试使用我知道会产生消息的主题中的消息(kafka producer已经设计好了，我所要做的就是编写一个使用这些消息的代码)。Configuration.prop.getProperty("suite.pusher.defaultParams.kafkaBrokers");
static String brokers = "<kafka_server_ipConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "300
浏览 4提问于2018-07-17得票数 0
回答已采纳
我有一个Java Kafka生产者，它使用org.apache.kafka.common.serialization.LongSerializer作为关键的序列化程序，并且我正在尝试使用Python Kafka消费者来消费主题中的消息。我认为既然LongSerializer是org.apache.kafka的一部分，那么在其他语言的所有官方Kafka客户端中都应该
浏览 2提问于2019-06-17得票数 3
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。我们需要Java 1.7 / 1.8来使用Stream API吗？
浏览 3提问于2018-12-20得票数 0
是否有更有效/更简单的方法来使用最新的Java客户端2.4API获取主题/分区的大小/最新偏移量？然后，通过将消费者组的偏移量与主题的大小进行比较，计算消费者群体的滞后.我知道以前的Kafka版本也问过这个问题，也有一种方法可以从Kafka公开的JMX度量中获取这些信息，但是我仍然被一个遗留应用程序困住了，它需要用Java来完成，但我需要使用最新的2.
浏览 2提问于2020-02-05得票数 3
回答已采纳
使用Java Client producer，可以在发布到主题之前对消息进行微调以符合模式格式。使用kafka rest proxy，如果消息无法用kafka avro模式版本反序列化，如何拒绝消息？这是为了防止不符合模式的客户端添加垃圾。我看到这个版本会自动升级到一个主题的新模式。如何限制消息发布到主题？这可能是由于所有bug的生产者客户端。
我正在搜索文档，我
浏览 33提问于2019-11-22得票数 0
1回答
我正在为kafka集群(使用dockers for kafka)为数据使用者编写解决方案，但我仍然需要决定如何对其进行编码：
真正的表演<
浏览 1提问于2018-12-20得票数 0
回答已采纳
5回答
如何通过kafka作为消息代理来使用mqtt协议？客户端(android/ios/桌面、java应用程序等)将使用mqtt phao客户端库来生成和消费消息，这些库有不同语言的版本，使用kafka作为消息代理。
有什么建议吗？
浏览 6提问于2015-10-28得票数 7
我有一个使用处理器api的拓扑，它更新了一个状态存储，配置了复制因子3，acks=ALL Topologies: Source: products-sourceproducts-source <-- products-processor 我的监控显示，源主题(< 100条记录)的延迟很小，但是支持存储的changelog主题有很大的延迟，达到数百万条记录
浏览 25提问于2020-11-28得票数 3
回答已采纳
1回答
Kafka JDBC connect兼容Spring-Kafka库吗？
我确实关注了，但仍然有一些困惑。
浏览 4提问于2020-07-04得票数 0
3回答
但是当涉及到选择一种语言来编写消费者时，我受到的约束相对较少。现在，有这么多的可以使用，我陷入了困境。任何帮助都将受到高度的感谢。
浏览 16提问于2016-09-17得票数 4
目前我们使用Apache NiFi通过Kafka consumer消费消息。kafka客户端的输出连接到hive处理器。
我正在研究如何在nifi集群上运行kafka消费者实例。我有3个节点的nifi集群和一个有3个分区的kafka主题，我希望kafka消费者能够在每个节点上运行，这样每个消费者可以从一个主题分区轮询消息。在我启动kafk
浏览 3提问于2019-08-04得票数 0
1回答
我们计划让生产者(Java rest api)和消费者(Java客户端)在多台机器上运行，并且所有消费者属于同一消费者组。1)在这种情况下，如果我在生产者发布Kafka写入随机/默认分区的消息时没有指定分区...
2)当消费者检索消息时，如果我没有提到分区，我会传递主题名称..and提交偏移量给Kafka服务器。如果我只有一个消费群体，这是一个好方法吗？3)我是否需要Kafka</
浏览 11提问于2016-02-24得票数 2
2回答
是否可以创建主题名称的别名？如果用户写到topic examplea，是否可以在代理上覆盖它，这样他们就可以真正写到topic exampleb？或者，如果主题实际上是作为examplea编写的，但消费者可以将其称为exampleb。我认为这可能可以通过在代理上使用小黑客来实现，在那里它回复元数据请求，但如果它可以以某种标准的方式完成，我宁愿不要这样做。
浏览 0提问于2016-06-26得票数 7
1回答
我们有一个WebSocket服务器，它为每个WebSocket客户端创建一个单独的消费者组，这样每个WebSocket用户就可以相互独立地接收来自Kafka主题的更新。我们使用camel API来创建Kafka消费者(组)，它使用了Kafka原生Java API，所以这与Camel没有任何关系，但提到camel只是一个FYI。通过使用JMX和JMC监控，我们发现Kafka心跳线程被
浏览 1提问于2018-11-06得票数 1
在Kafka中，一个消费者可以订阅的主题的最大限制是什么。我在任何地方都找不到这个记录的值。
如果消费者订阅了500000个或更多的主题，性能是否会下降。
浏览 6提问于2017-09-19得票数 5
1回答
我遇到了一个与Kafka消费者合作的特殊问题。当我有一个包含多个分区的主题和一个消费者组时，如果消费者数量小于分区数量，消费最终会变得不平衡。，什么都不做，而一些客户端有很大的延迟，正在努力工作，但却被落在了后面。请注意，我当然可以有8个客户端，但考虑到工作负载，我不需要8个客户端，我只需要4个，只是Kafka分配分区的方式实际上只有4个中的2个可以工作。我也可以手动分配分区，但这会使应用程序逻辑变得非常复杂，我对<
浏览 5提问于2020-05-12得票数 2
3回答
我有点困惑，当使用卡夫卡和动物园管理员时，偏移被存储在哪里。在某些情况下，补偿似乎存储在动物园管理员中，而在其他情况下，它们存储在卡夫卡中。
我使用我的NodeJS应用程序中的kafka节点连接到kafka
浏览 0提问于2016-12-14得票数 46
回答已采纳
2回答
我需要清除或删除卡夫卡主题编程使用C#语言。目前，我已经使用Confluent.Kafka库发布和消费卡夫卡主题。我可以使用这样的命令行删除Kafka主题是否有使用C#语言以编程方式清除卡夫卡主题</e
浏览 0提问于2018-12-27得票数 0
回答已采纳
3回答
我对软件开发很陌生。目前，我正在做一个项目，收集实时数据从传感器安装在不同的位置。每个传感器将每分钟向服务器发送数据。在未来，我期待着每分钟向服务器发送数据的100 K传感器。目前，我正在做以下工作。
我正在考虑为不同类型的数据处理编写单独的Node.js应用程序，如下所示。
将接收到的数据放
浏览 0提问于2017-09-02得票数 0
获得Kafka集群审计日志到GCP日志的不同方法是什么？有人能分享更多关于我如何实现它的信息吗？
谢谢!
浏览 0提问于2021-08-05得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
