1回答
我有一个应用程序，需要使用Kafka作为消息系统。我还有一个接受用户输入的GUI。应用程序被设置为在接收到来自主题的消息时启动繁重的处理。大部分数据来自消息，但我需要以用户输入信息的形式获取信息，以设置默认值。我必须使用Java 8，这是一个Java核心应用程序。我有一个继承的Java Swing UI，并不打算从头开始构建新的UI。我还想在完成
浏览 23提问于2021-03-29得票数 0
我一直在尝试从我的React应用程序中将这些数据(主题)读取到我的MSK集群中，我发现可以帮助我的工具和信息很少，但我没有成功
如何从MSK集群中获取此数据并将其显示在React表中？我找到的一些项目：、、、
浏览 19提问于2021-08-06得票数 0
我还可以通过ListConsumerGroupsResult list = AdminClient.listConsumerGroups()获取ConsumerGroups的列表。通过我的IDE和在线搜索，我没有找到这样的方法，但我想知道社区中是否有人这样做过。
浏览 4提问于2018-10-18得票数 1
Apache Beam和Apache Kafka在流处理方面有什么不同？我也在努力掌握技术和编程上的差异。
请通过您的经验报告来帮助我理解。
浏览 1提问于2018-06-15得票数 10
2回答
想要监视Kafka消息传递指标--主要是多少条消息被消耗或丢失，延迟，最终消费者补偿等等。是否有比从头开始编写(java)应
浏览 4提问于2017-05-12得票数 2
回答已采纳
我正在学习apache spark与kafka的集成，这样当新消息到达Kafka的主题时，我的代码就可以自动运行。我也读过官方文档 https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html 但我仍然对它的工作原理感到困惑我有我的字数统计写的程序在java火花
浏览 15提问于2019-12-10得票数 1
在普通的Java中，如果我用Serializable接口实现一个类，Java负责序列化该类的实例，反之亦然。如果我们使用Kafka，为什么我们需要提供单独的序列化程序和反序列化程序类？如果类实现了Serializable，为什么Kafka不能使用与Java运行时引擎相同的机制来序列化和反序列化实例？你能解释一下这个吗？
浏览 27提问于2019-08-12得票数 0
回答已采纳
我有超过50个源连接器通过sql服务器，但其中两个是错误的，请告诉我可能是什么原因，因为我们有限制访问kafka服务器。(TransformationChain.java:44)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.javaorg.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.ja
浏览 43提问于2020-06-23得票数 3
我正在尝试编写一个简单的Kafka消费者来读取windows机器上的数据。但是我的消费者不能读取任何数据。生产者产生了20多条消息，但没有一条消息被消费。下面是我为消费者编写的代码： properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIGdata.topic());
System.out
浏览 0提问于2020-05-13得票数 1
因此，如果我们在不使用datadog的情况下运行应用程序，并且当我们发布生产者的消息时，使用者就可以使用消息。结论：与datadog清晰地添加了消息头，消息不被传递给用户。此API用于注入和提取跟踪上下文。如果您使用的是混合版本环境，Kafk
浏览 6提问于2021-08-31得票数 0
1回答
我正在创建一个向kafka-rest-proxy发送大量数据的服务。我只是发送数据(生产)给卡夫卡。我发现kafka-rest-proxy很容易被淹没并耗尽java堆空间。我已经分配了额外的资源，甚至横向扩展了运行kafka-rest-proxy的主机数量，但我仍然遇到连接中断和内存问题。我不熟悉kafka-rest-proxy的内部结构，但我的直觉是它会缓冲记录并将它们异步发送给Kafka
浏览 31提问于2021-01-13得票数 1
当卡夫卡的消费者消费了卡夫卡的信息时，看起来-
{"type":"Buffer","data":[91,13 .....]当我在nodejs消费者中使用m.message.value.toString('utf8')时，它会打印实际消息。但我需要在java Kafka消费中消费。我试过用property.put("value.serializer.encoding", "utf8
浏览 0提问于2019-03-11得票数 0
我正在运行一个Kafka代理程序，通过Python程序将消息推送到其中。为了有效地进行数据交换，我使用Apache格式。在卡夫卡经纪人那里，这条信息是由一条带有处理器的骆驼路线接收到的。在这个处理器中，我想反序列化消息，并最终希望将数据推送到InfluxDB。 }) //
.to(influxdbEndpoint
浏览 10提问于2021-02-04得票数 2
回答已采纳
2回答
我有三个测试类来测试我的控制器、服务和Kafka消息传递。当我运行Kafka消息传递单机版时，它可以工作。但是当我一起运行我所有的测试文件时，只要Kafka测试类是第一个被执行的，它就会通过，否则它就会失败。我怎样才能做到这一点呢？我的应用程序是使用Micronaut、
浏览 5提问于2021-05-21得票数 1
为我的无知道歉。
我们正在建立一个实时数据库，捕获基于网站上的成员活动的记录。发出这些信息的应用程序是IBM MQ。我们计划将Apache Kafka设置为使用来自IBM MQ的这些消息，并将其存储在HBase for Analytics中。Kafka有没有可能直接将这些信息写入HBase，或者我们应该在Kafka和HBase之间设置一个像Apache Storm这样的实时流引擎？
浏览 1提问于2015-06-25得票数 1
我正在运行kafka_2.11-0.9.0.0和一个基于java的生产者/消费者。消息大小约为70KB时，一切工作正常。然而，在生产者将更大的70MB消息排入队列后，kafka似乎停止向消费者传递消息。即不仅不递送大消息，而且还递送随后的较小消息。我知道生产者成功了，因为我使用了kafka回调进行确认，并且我可以在kafka</
浏览 1提问于2016-02-03得票数 0
我正在使用星火应用程序中的Kafka向某个主题发送一些通知。我在我的Spark日志中看到了大量以下异常，并且消息没有传递到主题。15/09/08 03:29:24错误发件人: kafka生产者I/O线程中的未明错误： at org.apache.kafka.common.network.Network
浏览 7提问于2015-09-08得票数 1
回答已采纳
我正在使用kafka作为一个消息传递平台。我需要给它发一大堆信息。我在寻找一个可以记录记录列表的大容量api，但是在kafka-客户端工件中找不到它。
Java中的Kafka有批量生产api吗？
浏览 1提问于2015-10-06得票数 1
回答已采纳
1回答
我们计划让生产者(Java rest api)和消费者(Java客户端)在多台机器上运行，并且所有消费者属于同一消费者组。1)在这种情况下，如果我在生产者发布Kafka写入随机/默认分区的消息时没有指定分区...
2)当消费者检索消息时，如果我没有提到分区，我会传递主题名称..and提交偏移量给Kafka服务器。3)我是否需要Kafka rest代理，据我所知这不是必需的，因为我正在使用<
浏览 11提问于2016-02-24得票数 2
大家好，我在talend中遇到了一些卡夫卡输入的问题，如果在Talend作业中有任何Kafka输入组件，那么一些组件就会被困在启动中，就像在tExtractJSONFields_1组件之后的图片中看到的那样卡夫卡输入组件有什么特殊的配置吗？
浏览 3提问于2022-09-19得票数 0
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号