producer

0热度

2回答

我有一些问题，卡夫卡制片人，但我不知道我可以解决它我Maven的相关性： <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.10.1.1</version> </dependency> 如果我创建： Producer<S

0热度

1回答

如何保护进程间生产者消费者消息传递机制免受因一方崩溃而导致的损坏？

我在Windows上为一个生产者和一个消费者在共享内存中实现了一个进程间消息队列。我使用一个命名信号量来算空槽，一个信号灯入选计数满插槽和一个命名的mutex来保护共享内存中的数据结构。考虑，例如消费者方面。生产者方面是相似的。首先它等待对充分旗语然后（1）它需要由互斥下的队列中的消息，然后它用信号空信号（2）问题：如果消费者进程在（1）和（2）之间崩溃，那么有效的进程可以使用的队列中的

0热度

1回答

RabbitMQ与Arduino Uno

我第一次使用RabbitMQ和Arduino，我需要发布数据。所以我使用了PubSubCLient类。这是代码： #include <SPI.h> #include <PubSubClient.h> #include <Dhcp.h> #include <Ethernet.h> #include <EthernetUdp.h> #include <Dns.h> #include <Et

0热度

1回答

如何使用kafka-avro-console-producer？

如果我使用'kafka-console-producer' - 它会自动拾取JASS文件并正常运行（可以产生远程主题）。如果我使用“卡夫卡的Avro控制台生产者”与完全相同的配置但增加了架构属性 - 它抱怨JASS配置： 'Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.s

1热度

2回答

做更新版本的卡夫卡生产者仍然有“producer.type”？

旧版本的文档说这是基本属性之一。新版本的文档根本没有提及它。做更新版本的卡夫卡生产者仍然有“producer.type”？或者，新的生产者总是异步的，我应该调用future.get（）来使其同步？

0热度

2回答

使用分区获取kafka 0.8.0中生产者的分区数量对于方法

我们是否支持kafka 0.8.0版本中的生产者的partitionsFor方法？我想用这种方法来获得给定kafka主题的分区数量。如果此方法在kafka 0.8.0中不可用，那么在此特定版本的kafka中获取生产者中分区数的最简单方法是什么？

9热度

2回答

春季卡夫卡异步发送呼叫块

我正在使用Spring-Kafka 1.2.1版本，并且当卡夫卡服务器关闭/不可达时，异步发送呼叫块一段时间。它似乎是TCP超时。该代码是这样的： ListenableFuture<SendResult<K, V>> future = kafkaTemplate.send(topic, key, message); future.addCallback(new ListenableFutureC

0热度

1回答

如何在防火墙/代理服务器上配置kafka生产者？

我们在AWS上安装单节点kafka。我们能够在这种环境中运行卡夫卡生产者和消费者。但是，尽管我们的客户试图向我们的kafka代理发送消息（AWS环境之外），但他们的消息仍然滞留在他们的防火墙中。所以客户卡夫卡生产者是位于防火墙/代理服务器，如何使我们的客户在他们的最终绕过代理后通过卡夫卡发送邮件设置。

0热度

1回答

ActiveMQ，多个会话与多个连接

我想在我当前的项目中使用ActiveMQ，但是我对于何时利用多个连接感到困惑。由于我们可以在单个连接中创建多个生产者，那么需要多个连接。我试着在网上却无法找到任何有用的资源，可以帮助我理解它的深度找到它。这将是非常有益的，如果有人可以共享和ActiveMQ工作的他的实践经验，并帮助我们的理解，当创建每个生产者和当在同一个连接创建多个生产商的多个连接。

1热度

1回答

管道消费者/生产者：谁应该是消费者/生产者的父/子后叉

首先，对不起，如果使用不好的英语。在我的笔记中，我写过这个子进程通常是制作者，但我不明白为什么。在fork（）调用之后，消费者和生产者是谁？问题是：如果子进程是生产者，他会在父进程完成之前完成，这意味着子进程成为僵尸进程。关于这个问题，我试图了解小素描：