腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
关于
使用
Java
的
Kafka
生成器
java
、
apache-kafka
、
kafka-producer-api
我是卡夫卡
的
新手。当我试图通过生产者发送消息时,这个错误弹出。有谁能说出问题出在哪里? ? ?
浏览 17
提问于2020-12-10
得票数 0
2
回答
对于有多个分区
的
主题,如何保留消息序列?
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我想知道
关于
Kafka
如何维护消息序列
的
信息/解释,当消息被写入多个分区
的
topic时。例如,我有多个消息
生成器
,每个消息
生成器
都顺序地生成消息,并
使用
超过1个分区在
Kafka
主题上进行编写。
浏览 0
提问于2016-12-01
得票数 2
1
回答
使用
apache spark
的
Kafka
流媒体
apache-spark
、
apache-kafka
、
spark-streaming
我已经在本地机器上设置了apache
kafka
,并且工作正常,当我将一条消息发布到生产者中时,它立即在消费者提示中流动。 可以从我
的
本地文件夹配置连续文件流吗?我该怎么做呢?我可以编写一个
java
应用程序来配置我
的
生产者吗?
浏览 0
提问于2016-07-28
得票数 0
1
回答
Apache 0.8.2.1 -生产者(
Java
)不写消息
java
、
apache-kafka
我在CentOS环境中设置了ApacheKafka0.8.2.1,创建了一个主题,并通过命令行生产者/
使用
者发送/接收了一些虚拟消息。正如你在截图中看到
的
,效果很好。不,我正在编写一个自定义
生成器
,以便将我
的
消息从
Java
发送到主题。package de.jofre.
kafka
; import org.apache.
kafka
.clients.producer
浏览 4
提问于2015-08-05
得票数 0
回答已采纳
1
回答
kafka
.javaapi.*和org.apache.
kafka
.*之间有什么区别?
api
、
apache-kafka
我是
kafka
.But
的
新学习者,让我感到困惑
的
是,似乎有两个卡夫卡客户包。import
kafka
.javaapi.producer.Producer;import
kafka
.producer.ProducerConfig;import org.apache
浏览 3
提问于2015-03-27
得票数 14
回答已采纳
1
回答
Kafka
2.9.1 producer 0.8.2.1编译与运行时依赖关系
java
、
apache-kafka
、
kafka-producer-api
因此,在api 0.8.2中,Kakfa配置属性为生产者更改了;在通过该配置并让我
的
java
生成器
编译之后,我得到了一个异常。
生成器
针对
的
是我
的
Kafka
_2.9.1-0.8.2.1集群节点,我得到了
关于
DefaultSerializer不实例化
的
异常: Exception in thread "main" org.apache.
kafka
.common.KafkaExceptionat org.
浏览 1
提问于2015-10-02
得票数 2
回答已采纳
1
回答
linger.ms
的
异步卡夫卡生产者批次大小
java
、
asynchronous
、
apache-kafka
、
kafka-producer-api
我有一个
关于
优化
kafka
异步
生成器
流程
的
问题:配置batch.size和linger.ms在
使用
异步
生成器
时会产生影响?我之所以这样问,是因为我认为这些参数只会影响同步
生成器
,因为它会等待代理acknowledgment.In情况下
的
异步
生成器
,这不会产生影响吗? 另外,是否有任何配置参数可以优化异步
生成器
?
浏览 6
提问于2022-04-21
得票数 0
回答已采纳
3
回答
编译
Java
应用程序以利用
Kafka
java
、
maven
、
apache-kafka
我
使用
以下方法编写消息
生成器
: <dependency><groupId>org.apache.
kafka
</groupId> <versio
浏览 4
提问于2015-02-26
得票数 2
1
回答
Kafka
生产者
Java
并不是将消息分发给所有主题分区
apache-kafka
、
kafka-producer-api
我对
Kafka
非常陌生,今天我尝试创建
Java
生成器
,用于在不同
的
分区上生成
关于
Kafka
主题
的
消息。TestProducer类有以下代码:import
java
.io.InputStreamReader;import
kafka
.javaapi.pr
浏览 1
提问于2016-06-14
得票数 0
回答已采纳
1
回答
Kafka
使用
错误
的
类路径: org.apache.
kafka
.common.utils.Utils
java
、
apache-kafka
我正在尝试创建一个非常简单
的
Kafka
生成器
,并且目前正在遵循,除了我
的
生成器
没有partitioner类。Caused by:
java
.lang.NoClassDefFoundError: org/apache/
kafka
/common/utils/Utils at
kafka
.clie
浏览 2
提问于2015-02-06
得票数 4
回答已采纳
1
回答
如何
使用
nodejs或
java
在
Kafka
流
生成器
中创建大消息块(大于1MB)?
apache-kafka
、
kafka-producer-api
我试图在nodejs中
使用
Kafka
节点创建
kafka
制作人
的
消息块,但没有得到任何解决方案。因此,现在我正在
使用
Java
创建一个
Kafka
流
生成器
,我需要发送大小大于1MB
的
大型消息。我怎样才能在卡夫卡制作者中创造出大量
的
信息,并消耗同样
的
信息呢?
浏览 0
提问于2019-09-12
得票数 0
2
回答
kafka
生产者示例-类未找到异常
java
、
apache-kafka
我正在尝试运行
kafka
文档()中描述
的
kafka
生产者示例。然而,当我尝试运行
生成器
时,我得到了一个类未找到异常: com.t4g.app.RandomProducer.main(TestProducer.
java
:20)主线程
java
.lang.NoClassDefFoundError:
kafka
/producer/ProducerConfig异常,原因:
java
.lang.ClassNotFoundException: <
浏览 1
提问于2014-09-05
得票数 1
1
回答
NotEnoughReplicasException与min.insync.replicas
的
意外行为
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
消息由
kafka
-console-producer用acks=all生成,由
kafka
-console-consumer读取。(中有更多详细信息) 然后,我没有从console-producer生成消息,而是编写了一个配置与控制台
生成器
相同
的
java
生成器
,最后得到了以下异常。代理0上
的
错误副本管理器:错误处理附加在分区insync-0 (
kafka
.server.ReplicaManager)上
的
操作,对于分区insync,0是1,
浏览 1
提问于2019-11-24
得票数 1
回答已采纳
1
回答
Confluent 3.3无法在本地与
kafka
-avro-控制台-producer连接模式-注册表
apache-kafka
、
confluent-platform
、
confluent-schema-registry
下载合流开源3.3之后,在命令行进行一个简单
的
实验:confluent-3.3.0% confluent startis [UP]
kafka
-rest is [UP]connect is [UP]confluent-3.
浏览 0
提问于2018-06-28
得票数 0
回答已采纳
0
回答
如何在
java
中将表
的
增量从DB读取到
Kafka
Producer中?
java
、
apache-kafka
我正在尝试
使用
DB数据作为我
的
java
代码中
的
Kafka
生成器
。源数据不断增长(例如每秒20行)。每次向DB表中插入新记录时,都会从DB中读取整个数据并将其添加到
Kafka
主题中。我只希望将新添加
的
行发送到主题(即,如果表已经包含10行,并且向其追加了4行,则只需要将这4行发送到主题)。 如果我们也可以
使用
Kafka
API,有没有办法在
java
中实现这一点??
浏览 4
提问于2017-11-30
得票数 1
2
回答
具有默认分区
的
Kafka
生产者
apache-kafka
、
apache-flink
现在,我
的
kafka
生成器
正在将所有消息下沉到
kafka
主题
的
单个分区中,该主题实际上具有超过1个分区。Properties props = new Properties();props.putProducerConfi
浏览 0
提问于2018-08-28
得票数 0
1
回答
Kafka
持久化状态存储没有与python和
java
的
联合
使用
一起工作。
java
、
python
、
apache-kafka-streams
、
kafka-producer-api
、
confluent-platform
考虑用
java
编写
的
以下状态存储:
使用
此状态存储
的
是两个处理器。
java
中
的
生成记录 首先
使用
java
向主题user-setting-topic生成记录,然后
使用
java
将用户记录添加到状态存储,然后生成记录到主题告警主题,然后
使用
用户id userIdTo
浏览 6
提问于2020-02-29
得票数 1
1
回答
Kafka
将S3源代码与只读注册表连接失败
apache-kafka
、
avro
、
apache-kafka-connect
、
confluent-schema-registry
我正在尝试读取存储在S3中
的
avro记录,以便
使用
confluent提供
的
S3源代码将它们放回卡夫卡主题中。我已经有了具有正确模式
的
主题和注册表设置,但是当连接S3源代码试图将我
的
记录序列化到主题时,我会得到以下错误 org.apache.
kafka
.common.errors.SerializationException:错误注册Avro模式引起
的
:.在io.confluent.
kafka
.serializers.AbstractKafkaAvroS
浏览 7
提问于2022-07-07
得票数 0
回答已采纳
1
回答
Java
错误中
的
Kafka
生产者
java
、
apache-kafka
、
kafka-producer-api
我
的
动物园管理员服务器在端口2181上运行,
Kafka
服务器在端口9092上运行。我用
java
编写了一个简单
的
生成器
。但是,每当运行该程序时,它都会显示以下错误: USAGE:
java
[options] KafkaServer server.properties [--override property=value--override Optional property that should override values set in server.properties
浏览 0
提问于2018-06-15
得票数 0
回答已采纳
1
回答
连接到运行在WSL2 Ubuntu中
的
Kafka
java
、
windows
、
apache-kafka
、
windows-subsystem-for-linux
、
kafka-producer-api
下面是我
的
Kafka
代理配置port=9092advertised.listeners=PLAINTEXT://127.0.0.1:9092listeners=PLAINTEXT://127.0.0.1:9092 pro
浏览 9
提问于2022-03-18
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
关于Kafka java consumer管理TCP连接的讨论
Java:关于如何使用Java学习编程的最佳技巧
关于Kafka配额的讨论(2)
关于Kafka broker IO的讨论
关于Kafka 1.1.0 Fetch Session的讨论
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券