apache-zookeeper

    0热度

    1回答

    我一直试图在Kafka集群上运行我的生产者和消费者api,但它不工作。 1)动物园管理员是在一个GCP VM实例运行 2)卡夫卡正在另一个GCP VM实例运行 步骤如下: 步骤1)使用运行动物园管理员以下命令: bin/zookeeper-server-start.sh config/zookeeper.properties 个Zookeeper.properties: #the direct

    0热度

    2回答

    我们使用Confluent模式注册机构作为Avro模式回购。我所观察到的是Zookeeper中没有消费者偏移量管理。是否因为Schema Registry的设计方式 - 不是在Zookeeper中存储偏移量,而是在Kafka中存储偏移量,还是在Kafka中压缩日志/主题的情况下是标准设计模式?

    1热度

    1回答

    产生卡夫卡我有这个模块运行(所有地方): 的ZooKeeper 卡夫卡服务器 卡夫卡消费者 Python脚本 在剧本有send()电话: producer = KafkaProducer(bootstrap_servers=['localhost:9092']) producer.send('test', 'entry1') 每15秒左右。卡夫卡服务器上的几乎每一个send() 调用产生这些

    1热度

    4回答

    所以我新的C,并试图写一个程序,增加两个矩阵 程序1 #include <stdio.h> int main(){ int m,n,o,p,i,j; int mat1[m][n]; int mat2[m][n]; int result[m][n]; printf("enter the number of rows and columns for matrix "); scanf("%

    4热度

    2回答

    我已经为我的应用程序模块和其他模块进行了测试。他们工作正常,但我想运行所有的测试(应用程序模块和其他模块)toguether生成jenkins的三叶草报告。我该怎么办??创建另一个配置文件来调用其他配置文件? ---编辑--- 我对每个模块的bootstrap.php相同的代码,我想使用相同的每个模块,以避免代码重复。分辩现在我有两个模块的应用和问题,当我运行的PHPUnit它抛出我这个错误: *

    0热度

    1回答

    为了解问题... 我有一组与特定表相关的表。现在为了完成它们和“table_one”之间的关系,我只做了一张由以下主键组成的表格: id_table_one,id_table_many,id_table_many_type。 第一个表示table_one的id,第二个表示table_many的id(它们中的任何一个),第三个键是表示表的类型的字符串。 一个例子,具体而言: 1,1, “表1” -

    0热度

    3回答

    这是我的路由生成器。在这里,我试图从我的文件插入数据topic.Later,我通过我的主要方法,并使用骆驼上下文我运行它。我尝试了几个代码,但没有人帮助我。我正在开发Apache kafka的POC - 骆驼。 public class SimpleRouteBuilder extends RouteBuilder { @Override public void config

    -1热度

    1回答

    我已经创建了6个集合,每个集合有3个分片和2个副本(solr版本5.5.0)。几天后我的设置工作正常。但几天之后,我收到以下错误: Error while trying to recover. core=Collection1_shard3_replica2:org.apache.solr.common.SolrException: No registered leader was found a

    0热度

    1回答

    我正在开发一个应用程序,它备份了android文本消息,我能够将文本消息保存在xml文件中,现在我想将这个文件消息导回到android。 我don'nt知道如何做到这一点, 任何帮助将非常感激

    0热度

    2回答

    我'初学者卡夫卡 1 /我下载卡夫卡的1.0.0版本 2 /我在bith server.properties更改的数据目录位置和属性zookeeper.properties \设置\ server.properties \ CONFIG \ zookeeper.properties 3 /当我尝试启动动物园管理员和卡夫卡服务器 我有一个错误“Files was unexpected” D:\ ka