我已经在本地机器上设置了apache kafka，并且工作正常，当我将一条消息发布到生产者中时，它立即在消费者提示中流动。
可以从我的本地文件夹配置连续文件流吗？我该怎么做呢？我可以编写一个java应用程序来配置我的生产者吗？
浏览 0提问于2016-07-28得票数 0
kafka消费者正在从另一个主题中读取关于主题1中的数据处理是否成功或失败的信息，即主题2是否成功或失败。我正在启动我的消费者，然后将数据发布到主题1。.I想使生产者和消费者同步，即一旦生产者发布数据，消费者应该读取该数据的成功或失败消息，然后生产者应该继续处理下一组数据。
浏览 3提问于2017-08-01得票数 2
我想知道使用kafka流API而不是使用标准kafka生产者/消费者API和用Java在消费者中进行流处理会带来什么好处。
浏览 4提问于2022-04-25得票数 0
回答已采纳
我希望在这里得到一些关于kafka连接配置属性的澄清，我很难理解如何理解前缀，以及connect如何提取和使用属性。我假设kafka connect使用的java api客户端将从属性文件中提取连接属性。
浏览 0提问于2019-09-04得票数 0
所以我对Kafka还是个新手。我试图运行一个简单的Kafka消费者和生产者。当我运行我的消费者时，它在for循环之前输出hello。但是，在for循环中从来没有打印任何东西，这让我相信它一开始就不会进入for循环，消费者也不会使用来自生产者的消息。我在linux系统上运行这个程序。 有没有人能就生产者或消费者的问题给出建议？我展示了我的生产者和消费者代码，它们都只有几行代码。<em
浏览 171提问于2019-02-08得票数 1
2回答
Kafka Rest示例
、、、
有没有使用Java中的Kafka rest api的生产者和消费者组的好例子。我不是在寻找生产者和消费者的简单消费者或卡夫卡客户端的例子。任何帮助都会被接受。
浏览 2提问于2016-08-17得票数 3
回答已采纳
我想使用kafka-console-producer cli工具向使用事务客户端的主题发送消息。因此，看起来kafka控制台生产者，我相信它实例化了kafka.tools.ConsoleProducer类，要么没有调用initTransactions，要么在调用完成之前发送。下面是我用来运行kafka-console-producuer的命令行：
export KAFKA_OPTS="-Djava.security.auth.login.config=/tmp
浏览 11提问于2021-04-02得票数 0
1回答
我们计划让生产者(Java rest api)和消费者(Java客户端)在多台机器上运行，并且所有消费者属于同一消费者组。1)在这种情况下，如果我在生产者发布Kafka写入随机/默认分区的消息时没有指定分区...
2)当消费者检索消息时，如果我没有提到分区，我会传递主题名称..and提交偏移量给Kafka服务器。3)我是否需要Kafka rest代理，据我所知这不是必需的，因为我正在使用Java clien
浏览 11提问于2016-02-24得票数 2
我有以下架构：我很困惑
1) whetherI can run kafka producer, broker and consumer on sepa
浏览 6提问于2015-11-02得票数 0
回答已采纳
然而，例如，在REST API方面，我从未听说过数据流这样的东西。
也许有人能告诉我术语数据流在Kafka中的真正含义。顺便说一句，我知道在Kafka中有生产者和消费者。生产者将数据发送到代理，然后代理将其发送给消费者。
浏览 0提问于2021-05-02得票数 1
在kafka-producer KafkaProducer中有没有找到特定主题的订阅者数量的选项？
浏览 0提问于2016-11-22得票数 0
我有一个需求，我应该能够使用配置细节运行生产者和消费者，比如引导服务器和用户在运行时提供的键值serdes。在之前的项目中，我可以使用java Apache Kafka API来实现这一点，但我看不到使用spring-kafka API的任何方法，因为它只允许通过Spring java配置类或application.properties来定义生产者或消费者相关的配置。
浏览 14提问于2021-05-25得票数 1
1回答
我读到了卡夫卡的主题--分界理论，它提到In one consumer group, each partition will be processed by one consumer only.现在有两个案例：-在上述每一种情况下，PubSub是如何工作的？如果只有单个使用者可以连接到特定的分区，那么其他使用者如何接收相同的msg呢？
浏览 4提问于2022-08-22得票数 0
1回答
我们想要捕获Twitter流API。我们遇到了一个推特的制作人。如果制片人倒闭了，是不是意味着我们失去了一些数据？如何防止这种情况发生？
浏览 2提问于2016-01-12得票数 0
回答已采纳
我注意到，自从Kafka 0.8.2.0以来，Kafka附带了一个新的maven模块：
<dependency> <artifactId>ka
浏览 0提问于2018-07-21得票数 2
回答已采纳
根据我对以下文档的理解，消费者/侦听器可能需要@EnableKafka注释。https://docs.spring.io/spring-kafka/api/org/springframework/kafka/annotation/EnableKafka.html 这是否意味着，此注释适用于消费者的上下文，而不是生产者的上下文？
浏览 22提问于2021-11-09得票数 0
让我总结一下我迄今所理解的：
Kafka流可以用于进行一些ETL或Analytics --这意味着我们可以编写能够进行数据丰富和转换的Java代码，并将其插入卡夫卡自身？，以便实现精确的一次处理。在卡夫卡消费者生产者API中，只有当我们从一个主题读取消息，然后在同一集群中写入另一个主题时，才有可能实现这一目的。这将适用于Kafka事务(比如提交偏移量并使消息在输出主题上可见)。如果我们想要处理这个问题--我们将不得不使用收件箱模式--在这里，我们读取主题中的消息，将其写入数据库，然后由工
浏览 2提问于2022-10-04得票数 0
1回答
我真的需要第一个来制作消费者或生产者应用程序吗？<dependencies> <groupId>org.apache.kafka</groupId></dependencies>
我的生产者只使用第一个就可以工作得很好，但是消费者需要第二个。我曾认为"kafka</em
浏览 2提问于2016-02-17得票数 9
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。我们需要Java 1.7 / 1.8来使用Stream API吗？
浏览 3提问于2018-12-20得票数 0
我需要使用Java API将Kafka生产者偏移量与消费者偏移量进行匹配？
我刚接触KAFKA，有没有人能建议一下该怎么做？
浏览 0提问于2017-10-25得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
