1回答
我正在尝试通过kafka和json文件获取数据，并运行以下命令： bin/kafka-console-producer.sh --broker-list localhost:19092 --topic
浏览 14提问于2021-03-19得票数 0
1回答
我在这里询问的是关闭卡夫卡的消费者。即使使用线程退出，我也需要关闭kafka使用者吗？会不会因为任何改变而关闭它的资源？
浏览 0提问于2018-08-16得票数 3
回答已采纳
1回答
我正在应用程序中构建消息队列系统。生产者发送到队列的每一条消息都必须在使用者中传递和处理。绝对不允许数据丢失。但我找不到卡夫卡100%的送货保证。消息在队列中存储一段特定的时间或直到存储已满。但是，如果队列中仍有一些未传递的消息过期/超出，则这些消息<
浏览 4提问于2022-03-21得票数 0
我正在部署我的应用程序与卡皮斯特拉诺/乘客/nginx。部署进行得很顺利。然而，当我尝试加载它时，应用程序就会死掉：回溯的最后一行是：
/opt/app/releases/20101208120133/system/config/
浏览 0提问于2010-12-08得票数 0
我已经在远程服务器上部署了我的应用程序，使用了capistrano和git。我是卡皮斯特拉诺和吉特的新手，我的问题是：我对本地项目中的任何文件进行更改并添加代码，例如更改控制器或模型或视图中的2行代码、css或js或routes.rb或devise.rb...etc。我想知道如何将这些更改发送到我的vps远程服务器中的生产远程应用程序。cap deploy我不知道这一定是用卡皮斯特拉诺</
浏览 4提问于2012-03-21得票数 0
回答已采纳
1回答
我在一个Github，已经提交了所有的东西，并设置了deloy.rb文件和远程回购上的吉突。看来吉特·巴什和卡皮斯特拉诺没有联系。/usr/bin/env: ruby: No such file or directory
我做错了什么？
浏览 3提问于2009-07-23得票数 0
但现在我对卡皮斯特拉诺和红宝石有意见了。实际上，我想用capistrano部署一个php应用程序。我有以下消息：/usr/bin/env: «ruby2.3»: No such file or directory
你知道如何解决这个问题并使用卡皮斯特拉诺吗？
浏览 1提问于2018-08-18得票数 0
回答已采纳
1回答
当一个消费者从一个群体中掉下来，一个再平衡被触发，我知道没有信息被消耗-或者卡夫卡在再平衡过程中是否将有效载荷发回？还是卡夫卡等待最大的时间，并发送一个空的有效载荷？底线--我试图解释消费者的周期性超时。
这可能在文档里，但我不知道在哪能找到它。
浏览 6提问于2021-03-08得票数 0
2回答
我是卡夫卡和米洛诺的新手，我不懂@KafkaKey的用法。我在网上发现的是：
可以通过提供一个带有@KafkaKey注释的参数来指定Kafka键。如果没有指定此类参数，则使用空键发送记录。
浏览 3提问于2019-09-25得票数 0
1回答
豆荚间的沟通是通过卡夫卡进行的。它目前只登录到stdout。没有文件。没有卡夫卡的话题。这显然很糟糕。为了做到这一点，我发现很多人使用像Fluentd、FluentBit和Promtail这样的工具来集中日志并将它们发送给Loki。不过，我已经让卡夫卡跑了。如果我能够通过一个“日志”主题将所有日志发送到kafka，我就不明白为什么我会使用像logs一样的工具。
我的问题是:如何将日志主题中的所有<
浏览 9提问于2021-04-08得票数 1
回答已采纳
我想用RabbitMQ和Kafka的地铁做消息经纪人。我在启动.Net核心应用程序时配置了.Net和Kafka，在部署阶段通过appSetting可以决定哪一个必须注册。这种方法对于在我的应用程序中同时拥有和配置Kafka和RabbitMq是正确的吗？
浏览 0提问于2021-03-03得票数 1
回答已采纳
1回答
我是跟踪从的超分类账织物样品的平衡转移。我对它做了一点修改。我增加了第三个组织。一切都很顺利，直到我尝试用
错误：(/home/atif/Desktop/hyper-ledger/fabric/fabric-samples/balance-transfer/node_modules/grpc/src/node/src/client
浏览 0提问于2018-02-19得票数 0
涉及到一些外部遗留API调用，导致DB更改，发送几种电子邮件，一些回复到其他队列，输入消息被解析为磁盘。我们正在考虑使用Kafka与Kafka流，因为它是很好的但是我想知道在Kafka流中进行实际处理是否是个好主意，因为它涉及到一些外部API调用？它意味着当前和所有后续
浏览 0提问于2021-01-19得票数 1
我在给卡夫卡写短信和时间戳。如果我重试，时间戳可能会改变，编写的生产者也会改变，但是消息内容和消息id是相同的。消息id是在消息到达之前生成的，它是一个uuid。我如何确保卡夫卡不接受第二份，如果它成功地写到了主题，但它失去了，所以服务上链重试？消费者绝不能看到重复的消息。
浏览 1提问于2018-02-18得票数 0
1回答
然后我给这个话题发了一条卡夫卡的信息。我观察到2)无法访问rest。我认为如果吊舱的准备探测器失败了，应用程序既不能接收kafka消息，也不能接收其余的请求。但是为什么在我的测试中，其余的请求和卡夫卡消息的处理方式不同。我的实际意图是使我的服务应用程序(kafka使用者)能够控制何时接收kafka消息(以及REST请求)。例如，如果操作繁重，我的服务将删除/tmp/healthy文件，从而使吊舱无法接收kaf
浏览 3提问于2019-11-21得票数 4
回答已采纳
我在我的Windows电脑上运行了和Apache服务器。问题在于Spring应用程序:每当我启动它时，它都会从Kafka读取相同的消息。这意味着偏移量没有被保存。我该怎么解决呢？在卡夫卡的听众bean里，我有当Spring启动时，控制台上打印的使用者配置值如下
浏览 1提问于2021-06-10得票数 1
回答已采纳
我是卡夫卡和KafkaJS的新手。例如，我有一个生产者，它每秒产生一条消息，让它等待5秒。然后，当我启动使用者时，使用者将得到所有5条消息。(只运行一个使用者，一个组，一个分区，与生产者相同的主题)。
在KafkaJS上是否有只获取最后n条消息的配置？
浏览 2提问于2021-10-04得票数 1
回答已采纳
大家好，我在talend中遇到了一些卡夫卡输入的问题，如果在Talend作业中有任何Kafka输入组件，那么一些组件就会被困在启动中，就像在tExtractJSONFields_1组件之后的图片中看到的那样卡夫卡输入组件有什么特殊的配置吗？
浏览 3提问于2022-09-19得票数 0
回答已采纳
我正在使用Rails 5和Ruby2.3.3<head> <meta http-equiv="X-UA-Compatible
浏览 5提问于2017-02-21得票数 1
回答已采纳
1回答
一些应用程序调用另一个应用程序，随着时间的推移，调用其他应用程序时，管理和扩展变得越来越困难。我需要能够在一个网络中分发它们，并将不同的“流”中的应用程序与对应用程序的最小变化结合起来。理想情况下，我想包装应用程序，并将它们抽象成具有N个输入和M输出的组件。在启动时，我会使用一些配置将输入和输出连接到真正的kafka主题队列。我希望能够改变队列而不必重新编译应用程序，也不需要额外的网络跳来发送/接收多个队列，这应该是在相同的进程和多线程。
有没有人知道类似的东西是否已经存在？spring集成可以
浏览 6提问于2018-01-09得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
