kafka-producer-api

    0热度

    2回答

    我可以在Kafka Broker的同一台机器上运行Kafka Streams应用程序吗？

    我有一个卡夫卡流应用程序，它从几个主题中获取数据，并加入了数据，并把它放在另一个话题。 卡夫卡配置： 5 kafka brokers Kafka Topics - 15 partitions and 3 replication factor. 注：我在哪里我的卡夫卡经纪人运行相同的机器上运行卡夫卡流应用。 的几百万美元的记录被消费/制造每隔一小时。每当我拿下任何一家卡夫卡经纪商时，它都会进入
    apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-09-12

    1热度

    1回答

    Kafka Stream重新平衡旧消息

    我有一个Kafka Streams应用程序，它从少量主题获取数据并加入数据并将其放入另一个主题中。 卡夫卡配置： 5 kafka brokers Kafka Topics - 15 partitions and 3 replication factor. 我运行在哪里我的卡夫卡经纪人正在运行同样的机器卡夫卡流应用。 每小时消耗/产生几百万条记录。每当我把任何一个卡夫卡经纪人放下时，它会在重新
    apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-09-13

    0热度

    1回答

    KafkaProducer sendOffsetsToTransaction需要偏移+ 1才能成功提交当前偏移量

    我正试图在Kafka Processor中实现一个事务，以确保不会再次处理相同的消息两次。给定一条消息（A）我需要创建一个将在事务中的另一个主题上产生的消息列表，并且我想在同一事务中提交原始消息（A）。从文档中我发现Producer方法sendOffsetsToTransaction似乎只有在成功时才能在事务中提交偏移量。这是process()方法我Processor内部的代码： producer
    scala apache-kafka kafka-producer-api apache-kafka-streams 2017-09-13

    0热度

    1回答

    如何从RD Kafka客户端中的文件读取配置值？

    我使用LIBRDKAFKA C库开发了一个RD Kafka客户端。 LIBRDKAFKA C库公开了set_config API来为Consumer和Producer Handles设置配置值。有大约数百个可用的配置可供设置，对于每个值，set_congig变得非常繁琐。重要的是，它在代码本身中设置配置的效率不高，因为我们没有灵活性来根据不同的平台调整配置值，因为它需要RD Kafka客户端的重新
    kafka-consumer-api kafka-producer-api 2017-09-15

    1热度

    1回答

    卡夫卡制作人'request.timeout.ms'的含义让我很困惑

    嗯，我发现卡夫卡0.8.2的request.timeout.ms的含义与卡夫卡0.10.0不同。 https://kafka.apache.org/082/documentation.html https://kafka.apache.org/documentation/ 卡夫卡0.8.2： request.timeout.ms 的时间量的经纪人将等待试图满足发回一个错误给客户之前，request
    apache-kafka kafka-producer-api 2017-09-15

    0热度

    1回答

    wurstmeister kafka LEADER_NOT_AVAILABLE错误

    我试图使用下面的链接设置kafka集群。 https://github.com/wurstmeister/kafka-docker ，当我尝试制作一些味精我得到这个错误之下。现在 [2017-09-20 17:00:53,160] WARN Error while fetching metadata with correlation id 3 : {topic=LEADER_NOT_AVAILAB
    apache-kafka kafka-consumer-api kafka-producer-api 2017-09-20

    0热度

    1回答

    分割主题数据

    我想一个主题分成serveral的主题，基于数据的特定字段。是否有可能在流媒体中进行这样的操作？ 或者我应该写一个典型的消费者和生产者？ 例： 输入主题：数据与属性A（值AAA，BBB，CCC），B，C，d和E 输出主题：3个主题使用名称AAA，BBB和CCC具有相同的数据作为输入主题 此致 卢卡斯
    apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-09-22

    2热度

    1回答

    升级卡夫卡客户从0.8.2.0到0.11.0.0

    目前，在我的公司，我们正在迁移从卡夫卡0.8至0.11，经纪人迁移步骤，并明确卡夫卡文档here 什么我陷在是，升级中陈述客户端（生产者，消费者，火花流），我没有找到任何文档/文章清楚地列出了需要的更改或步骤来跟随客户端，我发现的所有内容是java doc Producer Client 我到目前为止所做的是将我的gradle中的kafka客户端版本更改为kafka-clients-0.11.0.
    apache-kafka kafka-producer-api 2017-09-27

    2热度

    2回答

    kafka-client 0.8.2.1是否支持ssl

    我们有配置为0.10.2.1版本的SSL的kafka代理，但我们需要使用Kafka客户端0.8.2.1编写生产者。此客户端版本是否支持SSL安全性？
    apache-kafka kafka-producer-api 2017-09-29

    -1热度

    1回答

    如何从kafka文件中读取日志？

    我想读取kafka中的Apache日志，然后进一步处理Spark Streaming.I是kafka的新手。据我了解，我必须编写一个生产者类来读取日志文件。
    apache apache-kafka spark-streaming kafka-producer-api 2017-10-01
最新问题