1回答
我已经尝试将引导属性设置为：获取错误:在身份验证期间终止到节点-1 (/xx.xx:9092)的连接。这可能是由于以下任何原因造成的：(1)身份验证失败是由于代理的凭据无效，代理的年龄超过1.0.0；(2)防火墙阻塞Kafka TLS通信量(例如，它可能只允许HTTPS通信)；(3)瞬态网络问题。spring.kafka.properties.security.protocol=SASL_SSL
引发的抛出: java.lang.Ille
浏览 2提问于2020-03-02得票数 1
我们试图从kafka 0.8升级到0.9，我们希望使用作为0.9的一部分发布的kafka consumer offset management。到目前为止，我们将偏移量存储在数据库中，并编写了我们的自定义消费者，它将检查数据库中的偏移量，并从kafka获取消息。
我们如何才能将这些偏移量迁移到kafka。我读过关于kafka offset从zookeeper迁移到kafka的文章，但没有发现任何关于这方面的东西。
浏览 0提问于2016-04-08得票数 0
我正在对Kafka进行调查，以评估它是否适合我们的用例。你能帮我理解一下Kafka在改变现有集群大小时有多灵活吗？
我正在对Kafka进行调查，以评估它是否适合我们的用例。你能帮我理解一下Kafka在不拆掉集群的情况下向现有集群添加brokers的灵活性吗？这样做的时候有什么需要注意的吗？
浏览 2提问于2019-01-08得票数 0
在使用新的Kafka版本2.1.0和Storm版本1.2.2开始使用Kafka Spout开始拓扑时，获得了一个java.lang.ClassNotFoundException: kafka.api.OffsetRequest当我使用Kafka版本0.10.0.1时，我没有得到这个。你们能帮帮忙吗，因为我想上最新的Kafka版本？ 我已经尝试了所有最新的kafka版本，从2.*开始。但不是works.Caused by: java.lang.ClassNotFoundException:
浏览 16提问于2019-02-07得票数 0
回答已采纳
1回答
我正在研究系统设计和数据流，对何时使用卡夫卡或动力感到困惑，起初我认为它们是一起工作的，但我仍然不太确定这是否正确KINESIS(process the data stream) --> KAFKA(publish the events on a queue) -->
MICROSERVICE THAT WOULD CONS
浏览 1提问于2022-04-25得票数 0
我从卡夫卡的话题中吸取了德鲁伊的数据。现在我想把我的卡夫卡主题转移到新的卡夫卡集群。在不重复数据和不停机的情况下，有什么可能做到这一点？在两个卡夫卡集群中生成数据:在新的Kafka cluster.Start中创建一个具有
浏览 21提问于2022-05-10得票数 0
为什么不推荐使用kafka-consumer中的zookeeper，为什么建议使用bootstrap服务器？bootstrap-server有什么优点？
浏览 0提问于2017-09-12得票数 36
回答已采纳
我们正在将我们的应用程序从Apache迁移到聚合平台。Apache版本:1.1.0
请对此提出更好的建议。
浏览 0提问于2018-10-05得票数 0
1回答
我正在从Spring迁移到Spring数据流。当我寻找模块列表时，我意识到有些源没有在中列出--其中之一就是KAFKA源代码。
我的问题是为什么在春云数据流中从标准源列表中删除KAFKA源？
浏览 4提问于2016-07-24得票数 4
回答已采纳
在Kafka 2.X中，TopicAndPartition被弃用，如何在将Kafka从较低版本更新到较高版本时进行修复
浏览 25提问于2021-08-26得票数 0
我正在使用Kafka将数据从Oracle db迁移到Hadoop文件系统(在这里是新的)。我已经在oracle上配置了我的摘录，它将在我的源表中所做的更改发布给我的kafka处理程序使用者，我可以看到有关我的主题的数据。现在，我想在kafka连接处理程序上做同样的工作，我希望在我的hdfs中的一个文件上使用模式和数据。我知道我可以配置kafka处理程序来读取我的提取跟踪文件。但是，我应该将目标hdfs的细节放在哪里，以便kafka可以
浏览 0提问于2019-05-13得票数 0
回答已采纳
我希望将一个4节点的Kafka集群迁移到一个新的集群，每个代理上有大约300 on的数据。问题是我们目前运行的是Cloudera的Kafka (CDK)，我们想运行Apache Kafka。在大多数情况下，CDK与Apache Kafka非常相似，但我正在尝试找出最好的迁移方法。我想知道我们是否可以启动一个新的Apache Kafka集群并将其添加到CDK集群中(如果有的话，还不确定这将如何工作)，然后一次一个地停止CDK服务器。否则，除了创建一个新的
浏览 1提问于2019-10-22得票数 0
我想使用Kafka 0.10 API和Java一起创建一个代理集群。据我所知，kafka_2.11-0.10.0.0.jar支持使用以下方法创建代理：import kafka.cluster.Cluster;我最近读到了1，它告诉我如何使用Kafka API在Java中创建一个主题。我们是否可以做类似的事情来创建代理集群、更新分区、将现有数据/分区迁移到新代理(因为这些新代理不会被自动分配给任何<em
浏览 1提问于2016-08-04得票数 4
1回答
我是Flink的新手，我需要从Kafka读取数据，通过使用一些API并写入S3，有条件地丰富这些数据(如果记录属于X类的话)。我还需要一个工作人员来处理来自队列主题-失败的数据。同样，如果API关闭了很长时间，则必须将此队列用作循环队列。
浏览 1提问于2020-03-05得票数 0
回答已采纳
将订购服务从Kafka迁移到Raft。据我们所知，订购服务从不对Fabric中的事务进行签名。此迁移是否会对旧ordere订购的旧事务产生影响？
浏览 20提问于2019-08-23得票数 0
回答已采纳
1回答
我已经为AWS数据迁移服务的Kafka目标配置了一个托管流，但是迁移任务失败了。看看这些日志，我看到了这个：2021-11-17T18:50:21 Messagedelivery failed with Error:[Local: Message timed out] [1026800] (kafka_records.c:16)
我已经核实了以下情
浏览 2提问于2021-11-18得票数 0
1回答
我刚刚开始和C# (dotnet core)一起使用Kafka。我使用docker (Confluent Images)创建了一个带有Schema Registry的Kafka环境。我将使用Kafka来处理服务之间的IntegrationEvents。 现在我已经通过Confluent UI创建了我的Kafka主题，但我真的喜欢将配置作为代码-等等。我使用EF核心迁移进行数据库迁移-使用TerraForm的云环境。 创建主题的最佳实践是什么？现在，我正在考虑在我的应用程
浏览 10提问于2020-10-01得票数 0
现在我想迁移到akka-persistence-cassandra。但是，如何将现有的事件(postgres中超过4 4GB的大小)转换为cassandra？
我应该写一个手动迁移程序吗？
浏览 1提问于2016-10-14得票数 4
我将结合使用AWS数据库迁移服务(DMS)和AWS MSK(Kafka)。我希望将同一事务中的所有更改发送到Kafka主题的同一分区-以保证正确的消息顺序(引用完整性) 为此，我将启用以下属性： IncludeTransactionDetails – Provides detailedThe default is false. https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Target.Kafk
浏览 19提问于2020-08-19得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
