1回答
我有一个应用程序，它使用AWS SQS和Lambda来处理推入队列的消息。Lambda会继续轮询队列，当出现新消息时，它会处理该消息。 在这种情况下，是否可以在AWS上使用Kafka替换SQS。换句话说，我们可以使用Kafka作为这个用例的队列吗？
浏览 20提问于2020-07-16得票数 0
1回答
我想知道卡夫卡和Netflix导体(而不是SQS)是否有一种简单的连接方式？目前，它似乎只适用于Amazon。此外，似乎只能按任务采取一项行动。是否有一种方法可以按任务执行多个操作？
提前谢谢你，
浏览 2提问于2017-06-12得票数 4
在处理SQS事件流时，如果Lambda函数没有足够的保留并发，则该函数将被限制，并且可以通过SQS重新驱动策略重试未处理的事件/消息。
浏览 13提问于2021-01-10得票数 1
. -> foo -> [outbound channel adapter] -> bar
我如何编写我的spring集成应用程序，以便foo可以使用一个额外的对象，该对象不是[outbound channel我的应用程序基本上是从AWS SQS接收消息(使用spring-integration-aws)，执行一些过滤/转换，然后将消息发布到Apache Kafka (使用spring-integration-kafka)，并且当且仅当此操作
浏览 54提问于2018-12-15得票数 1
回答已采纳
1回答
我做了一个poc，在其中我使用火花流读取来自Kafka的数据。但是我们的组织要么使用Apache或者Kafka使用者来读取Apache中的数据作为一个标准过程。所以我需要用Kafka消费者或者Apache来代替Kafka流媒体。在我的应用程序用例中，我需要从kafka读取数据，过滤json数据，并在cassandra中放置字段，因此建议使用Kafka</e
浏览 4提问于2017-03-26得票数 0
1回答
我从kafka开始，我需要控制特定Oracle表中的插入，现在通过kafka发送新记录。我无法控制数据库，所以原则上，Debizium被排除在外。我该怎么做？不用触发器。我让一个生产者使用eclipse中的java程序从Oracle读取数据，但是，这将对数据库发出不断的请求。我使用java与使用者一起模拟ETL。
PS:我和Windows一起工作，但那是次要的。
浏览 1提问于2019-07-07得票数 0
代表我的公司，我目前正在评估三种面向消息的中间件技术: Kafka、RabbitMQ和SQS.谁能给我一个提示，关于Kafka VS RabbitMQ VS SQS的支持和帮助资源，论坛和社区有多好？
浏览 0提问于2015-01-22得票数 1
我试图从Java应用程序向Kafka发送消息。(Main.java:26)host.name=192.168.0.1advertised.host.name=192.168.0.1运行的Kafka是kafka_2.11-0.8.2.1，所以我使用了(我猜)适当的Java版本：
<dependenc
浏览 3提问于2015-06-16得票数 3
回答已采纳
我对这类问题没有任何经验，但我有一个很好的websocket库，我很乐意使用。我排除了Apache，因为获得高吞吐量似乎很昂贵，开发操作(动物园管理员)很难管理，而且我不需要持久性，这只是2台机器之间的通信。所以我希望有一个简单的解决方案。
浏览 4提问于2019-10-27得票数 2
我正在使用kafka连接，以便从mongo读取数据，并将它们写入kafka主题。我使用的是mongo kafka源连接器。当我尝试反序列化时，到达我的侦听器的消息抛出以下异常。
浏览 1提问于2020-05-05得票数 0
config/worker.properties \> config/connect-file-sink-example_topic_1.properties
最后，我启动了一个用于发送消息的控制台生成器，我输入了一个message.sh bin/kafka-
浏览 0提问于2019-06-27得票数 1
回答已采纳
我有一个想要将消息从SQS移动到Kafka主题的用例。要使用的框架是SpringBoot。因此，无论何时我运行我的代码，它都应该开始移动消息。我搜索了一些文章，但很少。
浏览 7提问于2021-04-07得票数 0
我有一个完全围绕AWS构建的Microservice体系结构，还包括一个生产者/监听器，它通过SQS松散地耦合到业务Lambda函数。
浏览 3提问于2021-01-19得票数 0
1回答
我正在运行kafka生产者和消费者代码，以便在cdh 5.12中进行测试。当我试图这样做时，我在运行使用者代码时面临以下错误。:369) at org.apache.spark.sql.kafka010:369)
at org.apache.spark.internal.Logging$class.lo
浏览 0提问于2018-10-25得票数 2
1回答
我正在尝试将Apache Kafka 2.11-0.10.0.0与Apache Flink 1.1.2集成。我正在使用scala-shell对其进行测试，并得到以下错误。下面是我在shell中运行的代码 import org.apache.flink.streaming.util.serialization.SimpleStringSchemaFlinkKafk
浏览 13提问于2016-09-15得票数 1
回答已采纳
1回答
我正在尝试将Kafka主题数据写到本地Dynamodb。然而，连接器状态始终处于降级的状态。下面是我的连接器cofig属性。io.confluent.connect.aws.dynamodb.DynamoDbSinkConnector", "key.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converte
浏览 3提问于2021-09-05得票数 0
我正在开发一个应用程序，它从sqs队列中读取消息，对这些数据做一些处理，并将结果发布到kafka主题。为了在本地进行测试，我想在我的码头建造中设置一个卡夫卡图像。目前，我能够在本地使用docker旋转aws、local堆栈和我的应用程序的容器。另外，我也可以毫无问题地旋转卡夫卡和动物园。我无法得到我的申请与卡夫卡沟通。我试过使用两个独立的撰写文件，并且还篡改了网络。最后，我引用了：。container - '8080:80
浏览 0提问于2019-07-18得票数 0
回答已采纳
;import org.apache.kafka.common.serialization.StringSerializerat java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490) ~[na:na]
at org.apache.kafka.common.util
浏览 35提问于2019-08-10得票数 2
回答已采纳
1回答
我还有SQS源连接器，它将数据从SQS队列传输到我的Kafka主题。我想知道怎么做。，我需要在AWS控制台上工作吗？如何使用源连接器传输数据?
浏览 5提问于2021-04-23得票数 0
1回答
我试图使用SQS的方式与我们使用RabbitMQ或Kafka设置侦听器的方式相同。但是，我看不到在SQS文档中的任何位置设置SQS侦听器的方法： const client = new SQSClient({ },
const command = new ReceiveMessageCommand({ QueueUrl: process.env.SQS
浏览 3提问于2022-02-02得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
