Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何更改 Kafka 客户端日志记录级别/首选项?
我正在使用一个普通的 Java 项目来运行 无框架 Kafka 生产者和消费者 我正在尝试控制生成的日志KafkaProducer and KafkaConsumer代码 我无法使用log4j properties配置 log4j root
Java
logging
Log4j
kafkaproducerapi
保留期后的 Kafka 偏移量
我有一个带有 1 个分区的 kafka 主题 如果其中有 100 条消息 则偏移量将从 0 99 开始 根据 kafka 保留策略 所有消息都将在指定期限后被清除 一旦所有消息都被清除 保留期过后 我将向该主题发送 100 条新消息 现在
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
Kafka:使用java更改特定主题的分区数量
我是 Kafka 新手 正在使用新的 KafkaProducer 和 KafkaConsumer 版本 0 9 0 1 java中是否有任何方法可以在创建特定主题后更改 更新其分区数量 我没有使用 Zookeeper 创建主题 当发布请求到
Java
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
如何将消息发送到Kafka中的特定分区?
我创建了一个有很多分区的主题 使用控制台生产者 我想将消息发送到特定分区并通过控制台消费者查看 在控制台制作人上我尝试过这个 kafka console producer bat broker list localhost 9092 top
ApacheKafka
apachezookeeper
kafkaproducerapi
如何为 Kafka 生产者配置日志记录?
我正在使用 Kafka 生产者客户端 并且我的项目中没有任何 log4j 配置 运行时 程序会打印大量我真的不想要的 Kafka 调试日志 因此 我尝试添加 log4j properties 将日志级别设置为 ERROR 如下所示 这似乎不
Java
logging
ApacheKafka
Log4j
kafkaproducerapi
Kafka 0.10 Java消费者不从主题读取消息
我有一个简单的 java 生产者 如下所示 public class Producer private final static String TOPIC my example topi8 private final static Stri
Java
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
Kafka - 代理:消息大小太大
I get Message size too large当我尝试发送超过 1 Mb 大小的消息时出现异常 当我尝试生成消息时 该错误出现在我的客户端应用程序中 经过一番谷歌搜索后 我发现应该更改设置以增加最大消息大小 嗯 我在 kafka
ApacheKafka
kafkaproducerapi
kafka 新生产者在其中一个代理关闭后无法更新元数据
我有一个 kafka 环境 有 2 个经纪人和 1 个动物园管理员 当我尝试向 kafka 生成消息时 如果我停止代理 1 即领导者 客户端将停止生成消息并给出以下错误 尽管代理 2 被选为主题和分区的新领导者 org apache kaf
ApacheKafka
kafkaproducerapi
即使生产者得到了确认,Kafka 中也会发生消息丢失吗?
卡夫卡文档 http kafka apache org documentation design filesystem says Kafka 严重依赖文件系统来存储和缓存消息 现代操作系统提供预读和后写技术 以大块倍数预取数据 并将较小的逻
ApacheKafka
kafkaproducerapi
Amazon S3 可以作为 Kafka 集群的源吗?
Amazon S3 可以用作 Kafka 集群中的接收器 我想检查 Amazon S3 是否可以用作 Kafka 集群的源 卡夫卡连接 文件系统连接器 http kafka connect fs readthedocs io en late
amazons3
ApacheKafka
kafkaproducerapi
apachekafkaconnect
如何为 Kubernetes 中托管的多个应用程序选择 Kafka 事务 ID?
我有一个经典的微服务架构 所以 有不同的应用 每个应用程序可能有1 N实例 该系统部署到Kubernetes 所以 我们有很多不同PODs 可以随时启动和停止 我想实施读 处理 写模式 所以我需要 Kafka 事务 要配置交易 我需要设置一
Java
Kubernetes
ApacheKafka
springKafka
kafkaproducerapi
Java Apache Kafka Producer 元数据更新器和重试逻辑
我正在使用 Spring for Apache Kafka 并创建了一个服务 该服务通过 Spring 的 KafkaTemplate 使用 Kafka Producer org apache kafka clients Producer
ApacheKafka
kafkaproducerapi
Kafka 生产者 - 如何在不停机的情况下更改主题并保留消息顺序?
这个问题是关于架构和kafka主题迁移的 原来的问题 没有向后兼容性的架构演变 https docs confluence io current schema registry avro html 我请求社区给我建议或分享文章 我可以从中获
Avro
Messaging
kafkaproducerapi
获取发送到 kafka 主题的最后一条消息
我是 Kafka 的新手 正在开发一个原型来将专有的流媒体服务连接到 Kafka 我希望获取关于某个主题发送的最后一条消息的密钥 因为我们的内部流使用者需要使用连接时收到的最后一条消息的 ID 登录 是否可以使用 KafkaProducer
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
Kafka 多分区排序
我知道在 Kafka 中不可能对多个分区进行排序 并且分区排序仅保证组内的单个消费者 对于单个分区 然而 使用 Kafka Streams 0 10 现在可以实现这一目标吗 如果我们使用时间戳功能 以便每个分区中的每条消息都保持顺序 那么在
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
apachekafkastreams
«
1
2
3