回答情况：
提问时间：
问题标签：
我正在使用火花放电结构的流和读取数据从卡夫卡主题，这是Json复杂的格式。spark = SparkSession.builder \ .getOrCreate()
.readStream \ .option("
浏览 4修改于2021-01-27得票数 1
回答已采纳
我有Kubernetes ckuster创建与卡夫卡豆荚。为此，我使用docker image confluentinc/cp-kafka:5.3.2。
浏览 0修改于2020-02-14得票数 0
我已经实现了Kakfa从IoT网关接收数据(小系统运行在Linux上-它反过来连接其他设备并发送命令)，在IoT网关中写入数据，如日志，设备命令等。同样将用于平台上的分析等。现在，我想从我的中央平台(服务器-在云数据中心)发送命令到IoT网关我可以使用相同的Kakfa连接或需要切换到其他协议吗？
浏览 18提问于2017-06-17得票数 0
我们正在尝试使用作为源连接器连接到Oracle数据库。我们得到以下错误： "error_code": 400, ORA-01017: invalid username/password; logon denied\n for configuration Coul
浏览 10修改于2020-04-22得票数 0
我是kafka的新手，并遵循本教程kafka-topics.sh --list --zookeeper localhost:2181
浏览 17修改于2021-05-19得票数 0
每个应用程序都有自己的Kakfa服务器。来自这两个KAKFA服务器(代理)的消息发送到NiFi。非常感谢。你好啊，叶什维德
浏览 0提问于2018-12-17得票数 2
回答已采纳
我目前正在运行一组拓扑，我希望在运行时更改拓扑属性，如是否可以在不停止kafka流的情况下在运行时更改属性。我的一个想法是停止卡夫卡流，然后加载这些配置，然后重新启动。但似乎不是解决这个问题的理想方法。有人能提出更好的方法吗？
浏览 3提问于2020-03-31得票数 0
我有一个主题，在这个主题中，我从各种设备上获得了一系列事件。有n个设备每秒发出一次天气报告。对于设备1：- t1，t1(在同一时刻，然后间隔s秒) t2，t2(然后间隔s秒)，t3，t3我试图使用Kafka stream API提供的窗口和ktable的概念，但这似乎不太可能。有什么想法吗？
浏览 2修改于2018-07-08得票数 0
默认状态存储是rocksdb。我还可以找到内存中的状态存储。但是，我需要弄清楚kafka streams是否可以配置为使用mongodb作为状态存储，以及我是否可以自己定义这些集合。
浏览 7修改于2021-08-08得票数 1
我有一个包含3个代理的kafka集群和一个包含8个分区的主题。一个用java编写的生产者，使用了spring boot，没有自定义的负载均衡规则。这意味着它应该进行循环调度。可能的问题是什么？我使用的Kafka版本是0.10.1.1，另外注意，在这种情况下，我没有使用分区的副本
浏览 1提问于2020-05-29得票数 0
我有一个旧项目(它不是我的)，我正在尝试将它从Kafka 2.1更新到2.4。 我有下面这段代码 public synchronized void increasePartitions(String topic, int partitions) throws InvalidPartitionsException, IllegalArgumentException {
commandString.append("--alter");
commandSt
浏览 19修改于2020-03-26得票数 0
回答已采纳
我一直在做春云侦探，把痕迹推到zipkin，我们在spring-cloud-starter-stream-kafka和spring-cloud-sleuth-stream的帮助下把痕迹推到卡夫卡。compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-sleuth', version: '1.0.0.RELEASE'
compile group: 'org.springframework.cloud', na
浏览 1提问于2019-12-19得票数 0
我无法让spring-cloud-stream-binder-kafka在以下用例中工作： Start @transaction (Rest控制器) DB更新/插入发送Kafka消息 在事务提交之前，消费者(使用@EnableBinding和@StreamListener配置)能够读取记录。此使用者已配置了read_committed隔离级别。 我不确定这是一个问题还是我的任何配置。 尝试配置bean ChainedTransactionManager，但遇到了一些其他问题。
浏览 18提问于2020-03-18得票数 0
assembly_2.10/2.1.0下载了.jar之后[...] java.lang.ClassNotFoundException:Failed to find data source: kakfa类似地，我无法运行与Kakfa：集成的星火示例。
浏览 4提问于2017-03-20得票数 2
回答已采纳
我似乎在文档中找不到明确的使用AvroKafkaSerializer (具有模式支持)与在代码中“手动”序列化对象并将其作为字节/字符串发送相比的优点是什么？
浏览 20提问于2021-02-13得票数 0
回答已采纳
我正在将server表同步到雪花表。我可能会用卡夫卡来做这件事，并在码头中心找到了一个码头形象--沃斯特迈斯特/卡夫卡。我已经克隆了存储库wurstmeister/kafka-docker，并从克隆它的文件夹中运行了-d。在这里之前一切都很好。我现在想走下一步.
这些是我脑海中的问题，我被困住了。我真的很感
浏览 2修改于2019-03-08得票数 0
我正在与生产者和消费者一起构建一个简单的Kafka应用程序。我正在通过邮递员发送一条字符串并推介这个话题。主题是接收消息，但消费者并没有使用它。@EnableKafka@ConditionalOnProperty(name = "kafka.enabled", havingValue = "true") public KafkaListenerContainerFactory<
浏览 4提问于2022-05-24得票数 0
我正在学习spring boot和kakfa。我已经研究了一下，并配置了一个示例生产者应用程序，如下所示。但是，我不能发布这些消息。如果我能在这里缺少的东西上得到帮助就太好了。我已经启动了zookeeper服务和kakfa服务，并确保topic可用。HashMap<>();
// list of host:port pairs used for establishing the initial connections to the Kakfa
浏览 9修改于2020-05-06得票数 2
19880 -05-14 19:32:11.238信息2020- on(4)-127.0.0.1 o.s.c.support.DefaultLifecycleProcessor :在30000超时时间内关闭阶段值为2147483547的1个bean失败：
浏览 0提问于2020-05-14得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号