腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9)
视频
沙龙
1
回答
当我已经使用@Produces注释时,为什么我会得到一个“接口的模糊依赖”异常?
、
我有一个消费者接口IConsume,它由ConsumerRabbitMQ和
ConsumerKafka
实现。com.mycompany.chatapp.startup.MOMConfigBean.produceIConsume()], public void init() {} @EJB(lookup = &q
浏览 0
提问于2019-01-23
得票数 2
回答已采纳
0
回答
为什么Nifi
consumerKafka
_0_10处理器接收的流文件少于总的流文件?
、
、
我有一个生产者(PublishKafka__10处理器)和一个消费者(
ConsumerKafka
__10处理器)来接收来自Kafka集群的流文件。我不知道为什么在哪里丢失了3个来自
consumerKafka
__10 processor的包。 我使用带有3个节点的kafka集群和带有3个节点的nifi集群。
浏览 2
提问于2017-06-09
得票数 1
2
回答
NiFi:在FlowFile中更改文本(Python或.)
从我的处理器"
ConsumerKafka
“来看,好像所以,我必须删除'!'之前的任何文本,我知道一些Python。
浏览 14
提问于2021-12-23
得票数 0
1
回答
如何在apache nifi ConsumeKafka的同一处理器中添加更多的用户
、
如何在相同的nifi
consumerKafka
处理器中增加消费者?
浏览 25
提问于2019-12-28
得票数 1
2
回答
Apache nifi和kafka微服务
、
、
、
在Apache nifi仪表板中,我使用以下参数设置了一个输入: Kafka broker: localhost:9092Group ID: 1
ConsumerKafka
_2.6 : INPUT 然后我连接到这个漏斗的时候我只在
consumerkafka
框中看到了很多任务,但队列中没有连接到漏斗的元素。我希望看到收到的json,不是吗?我能错过什么吗? ? ? ?
浏览 37
提问于2021-07-14
得票数 0
1
回答
为什么在maxread值较大而消息接收数量较少的情况下,kafka消费者会变得无限?
、
、
、
import kafka.javaapi.consumer.SimpleConsumer; private List<String> m_replicaBrokers; m_replicaBrokers
浏览 0
提问于2015-01-08
得票数 0
1
回答
理解kafka动物园自动复位
我开始
consumerkafka
.jar时使用的是“ncdev1”和ZOOKEPER_AUTO_RESET = smallest的使用者组名称。可以观察到init偏移量设置为-1。
浏览 4
提问于2017-04-25
得票数 0
回答已采纳
1
回答
不能阅读卡夫卡主题使用卡夫卡消费者?
fis.close(); producer.close(); obj.producerKafka(configProperties); obj.
consumerKafka
浏览 17
提问于2017-12-21
得票数 1
1
回答
Kafka Zookeper -不尝试使用SASL进行身份验证(未知错误)
、
[main] org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/opt//Scripts/consumer/
ConsumerKafka
.jar
浏览 2
提问于2017-04-12
得票数 3
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何在Kerberos环境使用Flume采集Kafka数据并写入HDFS
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券