我有一个Kafka客户端，我需要测试它的功能。为此，我需要在本地创建一个Kafka集群，并连接到它。根据限制，我不能使用Docker镜像或K8s。我进行了搜索，发现在测试中使用了This class，但我不能更改代理端口。 我尝试使用Debezium KafkaCluster，但它间歇性地创建集群失败，因此导致间歇性测试失败。有没有办法在本地创建Kafka
浏览 18提问于2019-08-26得票数 0
回答已采纳
官方的.Net客户端似乎只提供了消费者和生产者功能。
(根据我对Kafka streams的记忆，很久以前)我相信Kafka Streams处理器总是运行在运行Kafka本身的JVM上。在这种情况下，这基本上是不可能的。
浏览 0提问于2018-02-16得票数 13
回答已采纳
根据Apache的文档，Kafka在其本地API的通信中使用了二进制TCP协议，但它们也为不支持Apache的本地API的语言提供了基于URL的restful。我只是想知道本地二进制TCP协议(在本机API中支持)是否比基于restful的与代理节点的通信有什么好处？我还在想restful是否还会维护only once属性呢？编辑: restful指南在这里：，它解释了如何在restful上生成和使用Kafk
浏览 1提问于2017-09-24得票数 2
回答已采纳
我想使用Apache Spark Structured Streaming和Kafka，Spark Structured Streaming支持Kafka 0.10及更高版本，我的Kafka集群使用kafka我想将当前kafka 0.8.2.1集群中的一些主题复制到基于2.2.0的新Kafka集群中。为此，我尝试在Kafka 2.2.0集
浏览 17提问于2019-05-23得票数 1
我想在我的本地机器上执行Kafka Consumer (Java代码)，而我的Kafka生产者和Kafka客户端在另一个Hadoop集群中？我可以使用kafka生产者脚本( kafka - console -producer.sh)向kafka集群发送消息，但无法在本地eclipse控制台中访问kafka消费者的消息？如果我们需要在配置方面做任何
浏览 1提问于2017-04-05得票数 0
9.0客户端使用来自运行在远程system.My生产者上的两个代理的消息的客户端运行良好，能够向代理发送消息，但我的使用者无法使用这些messages.Consumer，而producer在我的本地系统上运行(Schema.java:66)
at org.apache.kafka.common.requests.JoinGroupRequest.parse(JoinGroupRequest.javaa
浏览 10提问于2016-06-01得票数 5
回答已采纳
对我想要实现的目标做一个简短的解释:我想为avro做卡夫卡流拓扑(使用TopologyTestDriver)的功能测试。avroSerde;如果我在没有testDriver.pipeInput(recordFactory.create("topic", "1", createValidMappedTracking()));的情况下运行测试的话:82)
at io.confluent.kafka.serializers
浏览 1提问于2018-10-10得票数 4
我用jhipster创建了一个基本的应用程序，并添加了Apache Kafka。即使使用另一种解决方案(从我的应用程序到适用于kafka的php客户端)，我也没有任何生产和消费问题。现在，我想在集群上创建多个代理，但要从java而不是.sh文件创建。
我知道集群是使用server.properties文件设置的，其中隐含了代理的
浏览 1提问于2019-07-22得票数 2
我有一个函数，它接受Kafka streams的一个实例，获取状态存储，解析它并进行一些计算。.} 让我们假设Kafka流的拓扑是一个简单的拓扑，我们从一个主题中读取并将确切的记录存储在状态存储中。如何测试这些需要Kafka设置的函数
浏览 24提问于2020-10-09得票数 0
Apache Beam和Apache Kafka在流处理方面有什么不同？我也在努力掌握技术和编程上的差异。
请通过您的经验报告来帮助我理解。
浏览 1提问于2018-06-15得票数 10
我们有一个生产卡夫卡集群，最近被污染了一堆新的话题。Kafka集群具有以下设置：delete.topic.enable=false
经过调查，我发现这些主题是由一个使用KafkaStream的createTopic方法的客户团队创建的：org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster#createTopic(<
浏览 2提问于2017-12-17得票数 4
回答已采纳
我不是专家，但我知道身份验证机制通常与kafka一起工作。kafka的常见用例/实现使用SASL Plain或SASL SCRAM，即sasl.jaas.config = org.apache.kafka.common.security.scram.ScramLoginModule requiredusername pass
浏览 3提问于2021-06-12得票数 0
我有spring引导应用程序，它连接到我的kafka集群。应用程序(如kafka客户端)使用SASL身份验证，在初始化kafka生产者和使用者之前，我通过System.setProperty()指定了JAAS配置。它很好地工作在单卡夫卡集群设置。(别人的) kafka集群，它与我的kafka集群完全断开连接。第三方kafka集群
浏览 3提问于2020-07-22得票数 2
回答已采纳
据我所知，处理Kafka流的状态在内存、磁盘或Kafka主题中都是本地的，因为所有的输入数据都来自一个分区，其中所有的消息都是由一个定义的值键控的。大多数情况下，计算可以在不知道其他处理器的状态的情况下完成。如果是这样的话，您有另一个Streams实例来计算结果。如图所示：Flink到底在哪里存储它的状态？是否可以将Flink配置为将状态存储在Kafka代理中？
浏览 0提问于2019-02-10得票数 3
想知道如何从zookeeper似乎具有主题(T_60036)元数据的独特情况中恢复，但broker没有相应的日志文件，导致生产者失败并出现异常localhost:2181 get /brok
浏览 50提问于2018-06-07得票数 0
回答已采纳
我一直在尝试从我的React应用程序中将这些数据(主题)读取到我的MSK集群中，我发现可以帮助我的工具和信息很少，但我没有成功
如何从MSK集群中获取此数据并将其显示在React表中？我找到的一些项目：、、、
浏览 19提问于2021-08-06得票数 0
1回答
我有Istiov1.6.4的k8s集群。默认情况下，侧插入是禁用的。我让卡夫卡集群在这个k8s上运行，安装了strimzi操作符。卡夫卡集群的工作没有任何问题时，卡夫卡以及客户端吊舱没有注入Istio代理。我的问题是:当我用kafka客户端和Istio代理注入创建一个吊舱时，我无法连接到Kafka集群。客户端的日志：
j
浏览 4提问于2020-07-09得票数 7
我正在编写一个基于Kafka的集群应用程序--它专门使用Kafka进行进程间通信和协调。我可以使用Zookeeper来管理我的集群--但是使用Kafka主题来管理集群并不是很困难。我想得越多，除了出于历史原因，卡夫卡似乎可以放弃Zookeeper，只使用基于主题的解决方案
例如，在Kafka中可能会有一个或多个特殊主题，您可以在其中发布当前在Zookeeper中跟踪的</e
浏览 2提问于2016-03-08得票数 2
卡夫卡是新来的。这个处理0.8。
我看到有查询分区信息、主题等的方法，但是我看不出如何动态地创建一个主题。
浏览 4提问于2015-12-17得票数 8
回答已采纳
(CallCommand.java:79)\n\tat py4j.GatewayConnection.run(GatewayConnection.java:209)\n\tat java。Lang.Thread.run(Thread.java:745)\n‘，)
我使用的是星火流-kafka-assembly_2.10-1.6.0.jar(它存在于我所有节点+主节点上的/usr/lib/hadoop/lib/文件夹
浏览 3提问于2016-02-26得票数 4
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号