confluent-kafka

    0热度

    1回答

    超出保留期限的主题行为是什么?在他们的保留期限之后可以写信给他们吗?我一直在试图写信给他们confluent-kafka-dotnet(一个.NET库)但是当我运行一个消费者时,我没有看到任何消息流过。分区的值只是一个空字符串数组。是否可以写入超过保留时间的主题或该主题是否被禁用? using (var consumer = new Consumer(config)) { consum

    3热度

    2回答

    重新启动Kafka Connect S3接收器任务后,重新从主题开始处重新开始写入,并写入较旧记录的重复副本。换句话说,Kafka Connect似乎失去了它的地位。 所以,我想像Kafka Connect在内部connect-offsets主题中存储当前偏移位置信息。这个话题是空的,我认为这是问题的一部分。 另外两个内部主题connect-statuses和connect-configs不为空。

    0热度

    1回答

    我已经发现了一些代码在这里https://docs.microsoft.com/en-us/azure/hdinsight/hdinsight-dotnet-avro-serialization#Scenario2,它的扭转我需要什么: //Define the schema in JSON const string Schema = @"{ ""type"":""record"",

    5热度

    2回答

    有人能帮助我理解融合控制中心的时间线上的红色条纹是什么意思?

    0热度

    1回答

    汇合的高级消费者here具有以下代码(为了简洁起见而修剪)。 using (var consumer = new Consumer<Null, string>(constructConfig(brokerList, false), null, new StringDeserializer(Encoding.UTF8))) { while (!cancelled)

    0热度

    1回答

    我已经开始使用SSL配置kafka服务器。当我运行kafka控制台生产者时出现以下错误 sending message... Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update me

    0热度

    2回答

    我正在使用融合平台,动物园管理员处于活动状态查找状态。但是当我尝试用合流开始卡夫卡时,它显示动物园管理员已关闭。 $ sudo service zookeeper status Redirecting to /bin/systemctl status zookeeper.service ● zookeeper.service - Zookeeper Loaded: loaded (/

    1热度

    1回答

    当我配置hdfs连接器时,我设置了“flush.size=3”和“rotate.interval.ms=5000”,我感到困惑的是它是否会生成大量简单文件,例如:数以万计的文件的... 我不想更琐碎的文件,还有没有其他可能的解决方案? 另外,rotate.interval.ms和rotate.schedule.interval.ms有什么区别?

    1热度

    1回答

    我以前使用过融合的Kafka,通常我会更改位于/etc/kafka/的server.properties文件中的log.dirs=my-NEW-Location。 我刚在我的Ubuntu 16.04机器上安装了Confluent 3.3.0 ..使用命令confluent start kafka开始没有问题。我试图将server.properties中的log.dirs更改为我的新位置,但合流不会

    2热度

    1回答

    我是Kafka和Avro的noob。所以我一直试图让生产者/消费者运行。到目前为止,我已经能够生产和消费简单的字节和字符串,使用下列内容: 配置为制片人: Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer