腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
卡夫卡消费者在卡夫卡的原始实例下降之后,直到它恢复正常,才能得到数据?
、
我正在使用kafka控制台工具,并试图设置它,如果至少有一个kafka服务器实例仍然
在线
,仍然可以发送和接收消息,同时使用复制。(localhost:9092),
consumer
2 (localhost:9093)如果kafka1服务器处于联机状态,则无论kafka2但是,如果kafka1离线而kafka2
在线
,发送的消息就会被交换--抵消增加,但在kafka1恢复
在线
之前,
consumer
1和
consumer
2中的任何一个
浏览 6
提问于2017-02-28
得票数 0
回答已采纳
1
回答
Rx2 java,使用者接口
不
处理错误(套接字超时)。App崩溃
、
我有下面的订阅者来注册来自http服务提供者的接受,但是当url格式错误时,我会得到一个不可捕捉的异常,如下所示,即try-catch
不
工作。(当url有效时,没有问题)。 .observeOn(Schedulers.newThread()) .subscribe(new
Consumer
浏览 0
提问于2019-05-14
得票数 0
回答已采纳
3
回答
线程中的QTimer -事件
不
处理?
、
我
在线
程中创建了一个计时器,以便
在线
程运行时可以偶尔进行一些检查;但是,超时事件永远不会发生。 我也试过让计时器成为单机,但是没有发出任何事件。默认情况下,事件是
在线
程中处理的,还是需要进行其他处理?
浏览 0
提问于2010-07-30
得票数 2
回答已采纳
2
回答
RabbitMQ非阻塞用户
、
、
、
、
我在Python中使用RabbitMQ来管理一个生产者和多个消费者之间的多个队列。在RabbitMQ网站()中的示例中,消费者被封锁。这意味着每次队列中有一个新的“任务”时,它们都会停止在start_consuming()上执行回调函数。谢谢
浏览 1
提问于2014-02-19
得票数 18
2
回答
理解Java使用者示例很困难
、
、
我不理解关于Java
Consumer
接口的示例中的方法声明。我在一本
在线
书籍()中找到了这个例子。上面写着: };}
浏览 2
提问于2018-02-11
得票数 3
1
回答
Kafka消费者偏移量提交在可完成的未来
、
、
、
、
我
在线
程中创建了一个Kafka消费者实例,作为构造函数的一部分,
在线
程中的run方法中,我调用了不同的web服务,为了保持调用无阻塞,我使用了可完成的future。虽然在我的commit方法中,我已经编写了代码 commitResponse();我还是得到了ConcurrentModificationExceptionclass KafkaConsumerThread implements Runnable { KafkaConsumer<String, String&
浏览 1
提问于2017-09-23
得票数 1
2
回答
在android中使用社交身份验证在facebook登录集成中面临权限问题
、
大家好,我正在使用SocialAuth库在我的应用程序中集成Facebook,但在提供凭据后,下面附加的屏幕会出现。请帮帮忙。
浏览 4
提问于2015-11-19
得票数 0
2
回答
将最后一条信息发送给卡夫卡主题
、
、
// Poll so we know we're connected // Get the assigned partitions // Seek to the end of those partitions
consumer
.seekToEnd(assignedP
浏览 5
提问于2017-11-07
得票数 3
回答已采纳
2
回答
将一组对象从一个线程传递到另一个线程的最快数据存储是什么?
、
、
我有两个线程,一个读取流并从它们的内容产生数据对象。我希望将这两个任务分开(这就是我采用两个线程的原因),因为流和数据库上的I/O性能各不相同。在某些情况下,流是快速的,有时,数据库有一些滞后。我的第一个想法是FILO解决方案,必须是线程安全的,并且应该是快速的(没有花哨的东西,只是放和拉)。顺序并不重要。在某个时间,在存储器中可能有大约100,000个条目(这将是在与db大约一秒的ping之后的情况)。你有什么推荐给我吗?
浏览 1
提问于2012-06-22
得票数 3
回答已采纳
1
回答
看起来一切正常,但是函数retrieveRequestToken()抛出了'OAuthCommunicationException‘异常
、
、
、
我正在尝试使用函数retrieveRequestToken(
consumer
,CALLBACK_URI)获取uri,但它抛出了'OAuthCommunicationException‘异常。String AUTHORIZE_URL = httpsapi.twitter.comoauthauthorize;private static DefaultOAuthProvider provider;
consumer
= new Com
浏览 0
提问于2012-01-09
得票数 3
2
回答
Java Kafka使用者在多线程中的使用
、
、
我正在考虑
在线
程池中使用Kafka使用者。我想出了这个办法。现在它看起来很好,但是我正在考虑这种方法可能带来的缺陷和问题。基本上,我需要的是将记录处理和消费分离开来。final var
consumer
= new KafkaConsumer<String, String>(props); final) {
浏览 8
提问于2020-07-30
得票数 1
回答已采纳
1
回答
使用临时对象初始化线程
、
、
、
、
在线
程执行过程中,临时线程对象可能会超出范围。 在下面给出的程序中,我尝试了下面给出的两种方法,它们都运行时没有任何错误。#include<thread>{ {}{ { * Method 1 *
浏览 14
提问于2019-03-14
得票数 2
回答已采纳
2
回答
c++ lambda函数调用纯虚函数
、
、
、
、
std::unique_ptr<
Consumer
>
consumer
= std::make_unique<
Consumer
>();在executor kick方法中
浏览 91
提问于2018-06-03
得票数 5
回答已采纳
1
回答
C++单机多用户程序偶尔崩溃
、
、
、
在下面的代码中,我创建了一个producer thread和n
consumer
threads,它从每个专用的queue中读取并打印到stdout。->push(s); } } w
浏览 0
提问于2018-10-16
得票数 1
回答已采纳
1
回答
在两个进程之间共享全局变量
、
我试图在两个独立的进程中并发地运行两个while循环,其中第一个进程修改一个全局变量,而另一个进程根据该变量进行决策。这是我的密码:def loop1(): while (x<10): read = input("Enter 0 or 1") flag[0] = False flag[0] = True def l
浏览 0
提问于2017-05-04
得票数 1
回答已采纳
1
回答
PHP HMAC-SHA1函数没有返回"=“作为填充字符?
、
、
hmac_hash()函数,我的理解是算法应该在签名的末尾产生一个"=“作为填充,但是函数返回给我的签名从来没有这个填充,我想这就是为什么我不断收到来自oauth_signature的以下消息:”Tumblr
不
匹配预期值我已经尝试使用几个
在线
签名生成器来测试这一点,一些生成填充,一些
不
生成,所以我在这一点上有点困惑。下面是我的代码: 'oauth_callback' => $callback, 'oauth_
consumer
_k
浏览 2
提问于2014-09-11
得票数 0
1
回答
当我的BroadcastBlock发布时,为什么我的ActionBlock没有执行?
、
、
})); foreach (var producer in allProducers) foreach (var
consumer
in allConsumers) producer.LinkTo(
consumer
); }ID: 18上发布0
在线
程ID: 17上发布1
在线
程ID: 19上发布11
浏览 42
提问于2018-06-08
得票数 0
回答已采纳
4
回答
在发出等待条件变量的信号后,线程什么时候会获得锁?是什么决定的?
、
、
等待
在线
程B中被调用,它解锁互斥锁,允许其他人访问条件变量(用于信令)。然后,当条件变量
在线
程A中发出信号时,线程B唤醒,线程B再次锁定互斥对象。length %d\n", length); pthread_mutex_unlock(&mutex);} pthread_mutex_lock(&mutex); while(
浏览 2
提问于2015-03-03
得票数 2
回答已采纳
1
回答
如何使用twitter V2来流tweet?
、
、
但是我下面的
在线
教程使用了API v1。我看了文档,我知道我现在应该用(tweepy.StreamingClient)代替?但我找不到任何关于如何发送推特的例子。import tweepy bearer_token = ""
consumer
_secret = ''
浏览 9
提问于2022-08-18
得票数 0
1
回答
如何使用Confluent.Kafka在.Net中使用特定的.Net
、
、
、
、
= new
Consumer
<Null, string>(consumerConfig)) Console.WriteLine("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~Consume Started..."); { var cr = <em
浏览 0
提问于2018-12-29
得票数 12
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
kafka之consumer
Kafka consumer 解析
深入Kafka系列(二)consumer开发
Kafka技术内幕之Consumer Fetcher
聊聊kafka consumer offset lag increase异常
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券