consumer相关内容

每个 kinesis 分片有多个消费者

我了解到每个 kinesis 流可以有多个消费者应用程序. http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html 但是,我听说每个分片只能拥有一个消费者.这是真的?我没有找到任何文档来支持这一点,并且无法想象如果多个消费者从同一个流中读取会怎样.当然,这并不意味着生产者需要为不同 ..
发布时间:2021-11-27 10:18:48 其他开发

如何在 Javascript 中实现安全的 OAuth2 消费?

我正在用 PHP 设计一个将使用 OAuth2.0 的 API.我的最终目标是用 javascript(使用 AngularJS)构建一个直接访问这个 API 的前端应用程序.我知道传统上没有办法保护 javascript 中的事务,因此直接访问 API 是不可行的.前端需要与服务器代码进行通信,而服务器代码又直接与 API 进行通信.但是,在研究 OAuth2 时,似乎 User-Agent F ..
发布时间:2021-11-15 00:32:44 其他开发

Java 中的 Kafka 消费者

所以我目前正在学习 Kafka,并试图复制 Apache 提供的示例 这里.这是消费者的示例代码,我已经用 java 编写了它,如图所示.但是,当我尝试执行该文件时,我遇到了一些问题.我可以编译文件,但无法正常运行. 我使用以下不带引号的行执行程序,“java TestConsumer localhost:2181 group1 test 4"这传递了示例代码中必需的 4 个参数.但是当我执 ..
发布时间:2021-11-12 02:56:03 其他开发

Java 中的 Kafka 消费者

所以我目前正在学习 Kafka,并试图复制 Apache 提供的示例 这里.这是消费者的示例代码,我已经用 java 编写了它,如图所示.但是,当我尝试执行该文件时,我遇到了一些问题.我可以编译文件,但无法正常运行. 我使用以下不带引号的行执行程序,“java TestConsumer localhost:2181 group1 test 4"这传递了示例代码中必需的 4 个参数.但是当我执 ..
发布时间:2021-11-12 02:55:32 其他开发

如何从特定主题中删除 Kafka 消费者组?

我更改了监听 Kafka 主题的 Web 服务的消费者组 ID.现在,旧的组 ID 仍然注册到主题,但没有具有该组 ID 的消费者.因此,它是滞后的.如何从特定主题中删除特定的消费者群体? 我试过了: kafka-consumer-groups --bootstrap-server kafka01.myserver.com:9092 --topic notification-topic ..
发布时间:2021-11-12 02:15:14 其他开发

生成消息时找不到主题:UNKNOWN_TOPIC_OR_PARTITION

我有一个两节点的 Kafka 集群(EC2 实例),其中每个节点都用作单独的代理.当我使用以下命令在领导者实例上运行生产者时: kafka-console-producer.sh --broker-list localhost:9092 --topic 测试 我收到以下错误. 测试消息[2017-01-09 13:22:39,483] 获取关联 ID 为 0 的元数据时出现警告错误:{t ..
发布时间:2021-11-12 02:12:40 其他开发

Kafka 和 NodeJS 的实时通知

在我的项目中,我必须设计一个实时通知系统.我按照下图做了. 你可以看到我使用 Kafka 作为队列消息系统,使用 NodeJS 构建 Websocket Server 和 Kafka Consumers.生产者将收集通知数据并将其推送到 Kafka.如果数据属于该用户,消费者将从 Kafka 读取并处理数据,并通过 websocket 将其推送到客户端. 有了上面的架构师,每个在线用户 ..
发布时间:2021-11-12 02:11:55 其他开发

如果第一个代理宕机,Kafka 消费者将无法消费

我正在使用最新版本的 kafka(kafka_2.12-1.0.0.tgz).我已经设置了具有 3 个代理的简单集群(只是在每个实例的属性文件中更改了 broker.id=1 和 listeners=PLAINTEXT://:9092).集群启动后,我使用以下命令创建了主题 ./kafka-topics.sh --create --zookeeper localhost:2181 --repli ..
发布时间:2021-11-12 02:01:54 其他开发

Kafka Mirror Maker 无法复制 __consumer_offset 主题

我正在尝试利用镜像制造商将 __consumer_offsets 主题与其他主题一起复制. 它给出了如下所述的错误. [2018-10-24 16:16:03,802] ERROR 向主题发送消息时出错__consumer_offsets with key: 16 bytes, value: 445 bytes with error: (org.apache.kafka.clients ..
发布时间:2021-11-12 02:01:42 其他开发

将消费者偏移量重置为 Kafka Streams 的开头

我正在使用 Kafka 流,并希望将一些消费者偏移量从 Java 重置到开头.KafkaConsumer.seekToBeginning(...) 听起来是正确的做法,但我使用 Kafka Streams: KafkaStreams 流 = new KafkaStreams(builder, props);...流开始(); 我想根据我定义的具体流管道,这会在幕后创建几个消费者.我可以访问那些 ..
发布时间:2021-11-12 02:00:10 其他开发

消费者.如何指定要读取的分区?[卡夫卡]

我是用 kafka 介绍的,我想知道当我使用来自主题的消息时如何指定分区. 我找到了几张这样的图片: 表示1个consumer可以消费多个partition的消息,但是1个partition可以被单个consumer(在consumer group内)读取 另外,我已经阅读了几个消费者示例,它看起来像这样: Properties props = new Properties() ..
发布时间:2021-11-12 01:48:20 其他开发

检测到重复的基于 HTTP 的 FlexSession,通常是由于远程主机禁用了会话 cookie

场景描述:我的程序是通过flex+java+blazeDS+activeMQ实现的,它通过Flex Consumer从activeMQ订阅jms消息,目前我交付了两个tomcat同一个服务器,它们都包含我的程序,而 ActiveMQ 在另一台服务器上,现在我在同一种浏览器中打开这两个应用程序,例如作为 IE 或 Chrome,无论如何,url 就像 http://localhost:8080/He ..
发布时间:2021-11-12 00:21:22 其他开发

Apache Camel RedisIdempotentRepository 配置

有没有人能够成功地让 RedisIdempotentRepository 在 Camel Route 中工作? My Camel Route 是使用 Java 8+、Apache Camel (2.17.1) 和 Spring Boot (1.3.3.RELEASE) 构建的.Camel Route 加载和处理消息,但不会过滤掉重复的消息: from("activemq:generic.o ..
发布时间:2021-11-11 23:04:43 其他开发

异步 Camel 组件 - 立即调用 doStop()

我正在尝试创建一个使用来自外部服务的 API 的骆驼组件. 我的路线如下 from("myComponent:entity?from=&to=").to("seda:one")来自(“色达:一个").aggregate(constant(true), new GroupedBodyAggregationStrategy()).completionSize(5).completionTime ..
发布时间:2021-11-11 22:49:13 其他开发

如何在 Javascript 中实现安全的 OAuth2 消费?

我正在用 PHP 设计一个将使用 OAuth2.0 的 API.我的最终目标是用 javascript(使用 AngularJS)构建一个直接访问这个 API 的前端应用程序.我知道传统上没有办法保护 javascript 中的事务,因此直接访问 API 是不可行的.前端需要与服务器代码进行通信,而服务器代码又直接与 API 进行通信.但是,在研究 OAuth2 时,似乎 User-Agent F ..
发布时间:2021-11-09 03:07:03 其他开发

ActiveMQ Java STOMP 客户端收到 SocketTimeoutException

在 CentOS 机器上有一个 ActiveMQ 服务器.我可以使用 OpenWire JMS 客户端通过 TCP 和 HTTP 连接和使用消息.但是,当我尝试使用 ActiveMQ 测试 STOMP 客户端时,它会在 connection.receieve; 上引发此异常 java.net.SocketTimeoutException:读取超时在 java.net.SocketInputSt ..
发布时间:2021-08-30 19:31:28 其他开发

在消费者表达式中返回 Method 值

我正在尝试在方法中返回一个布尔值,并且我正在使用消费者函数.有没有办法直接在 Consumer 表达式中返回该值? 代码如下: private static boolean uuidExists(UUID uuid) {MySQL.getResult("", rs -> {尝试 {如果(rs.next()){返回 rs.getString("UUID") != null;}} catch ..
发布时间:2021-07-09 20:44:24 其他开发

如何停止使用来自选择性队列的消息 - RabbitMQ

QueueingConsumer consumer = new QueueingConsumer(channel);System.out.println(consumer.getConsumerTag());channel.basicConsume("queue1", 消费者);channel.basicConsume("queue3", 消费者); 是否可以单独动态地停止消耗来自队列“queu ..
发布时间:2021-06-30 19:29:19 其他开发