apache-kafka 相关问题

Apache Kafka是一个分布式流媒体平台，用于存储和处理高吞吐量数据流。

我看到很多关于使用offsetsForTimes的答案。我不能只读取时间戳大于给定时间戳的消息，而不是去offsetsForTimes。像下面的东西......

apache-kafka

回答 1 投票 0

Kafka Streams：topic.compression.type不是已知的配置

在Kafka Streams中添加压缩配置，与此链接类似：properties.put（StreamsConfig.topicPrefix（TopicConfig.COMPRESSION_TYPE_CONFIG），“snappy”）;但我看到以下......

java apache-kafka apache-kafka-streams

回答 1 投票 1

Kafka主题的JSON中没有发生结构化流 - 流连接

应用程序监听2 kafka主题userevent paymentevent Payload for userevent {“userId”：“Id_223”，“firstname”：“fname_223”，“lastname”：“lname_223”，“phonenumber”：“P98202384_223”，“usertimestamp”：“.. 。

java apache-spark apache-kafka spark-streaming spark-structured-streaming

回答 1 投票 0

如何在没有源的情况下使用Kafka频道配置Flume？

如果配置中未指定源，则会抱怨。根据文件：Kafka频道可用于多种场景：使用Flume源和接收器 - 它提供了可靠的...

apache-kafka channel flume

回答 1 投票 0

Vault for Kafka分布式连接器

我使用基于JBoss的保险库来保护敏感数据，例如数据库凭证。我使用基于Java的HTTP REST客户端来创建分布式Kafka连接器，但最终得到了一个安全性......

apache-kafka apache-kafka-connect

回答 1 投票 0

从Kafka主题消费消息时反序列化的问题

我正在使用Kafka Consumer API来构建使用者。消息结构很复杂。为了构建反序列化器，我实现了Deserializer类并提供了必要的实现。我...