我正在尝试读取Kafka主题中的记录，该主题是由kafka connect jdbc源连接器生成的，以下是连接器配置： "name": "customers", "poll.interval.ms:5.5.1，confluentinc/cp-schema-registry:5.5.1，confluentinc/cp-kafka-connect:5.5.1 我使用<em
浏览 670提问于2021-02-01得票数 0
回答已采纳
我目前正在三个节点集群上部署Kafka连接集群。我的集群是一个cloudera (Version5.x)，它设置了kerberos。在尝试Kafka之前，我成功地设置了一个主题，用于生产者和消费者控制台实现。我认为，准确地说，这在过去是可行的，这可能是相关的。我遇到了这个错误：
牧民工作线程中的(org.apache.kafka.connect.runtime.distributed.DistributedHerde
浏览 1提问于2021-02-10得票数 0
1回答
假设我的主题中已经有10个数据，现在我开始编写Flink，消费者将使用第11个数据。
任何帮助都是非常感谢的。示例代码(我尝试了FlinkKafkaConsumer08、FlinkKaf
浏览 1提问于2018-10-31得票数 2
回答已采纳
我正在尝试部署管道，它从Kafka集群读取，处理其记录，然后将结果写入BigQuery。但是，在尝试部署时，我始终遇到以下异常：
org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching我能够使用Compute连接Kafka服务器的套接字，在与要部署的Dataflow作业相同的VP
浏览 4提问于2020-04-23得票数 1
我使用flink流和flink-连接器- kafka来处理kafka的数据。当我用FlinkKafkaConsumer010 ( 1586852770000L)配置setStartFromTimestamp时，卡夫卡主题A中的所有数据时间都在1586852770000L之前，然后向主题A的分区-0和分区-4发送一些消息(主题A有6个分区，当前的系
浏览 6提问于2020-04-15得票数 0
回答已采纳
1回答
我想设置配置，我的应用程序跟踪使用的信息从卡夫卡。因此，无论何时失败，它都可以从最后一次提交或使用的偏移量中选择。readStream .option("kafka.bootstrap.servers", "host1:port1,host2:port2") .load()
.selectExpr("CAST(key AS STR
浏览 0提问于2021-02-12得票数 2
回答已采纳
我有一个Kafka消费者，我创建了一个时间表。它尝试使用自上次提交以来添加的所有新消息。 我希望在消费者使用完日志中的所有新消息后将其关闭，而不是无限期地等待新消息进入。我很难通过Kafka的文档找到解决方案。我在Confluent.Kafka.ConsumerConfig和ClientConfig类中看到了许多与超时相关的属性，包括FetchWaitMaxM，但是我不知道该使用哪一个。我使用<em
浏览 22提问于2019-02-15得票数 5
使用Apache Kafka Java client (0.9)，我尝试使用向代理发送一长串记录。
异步会立即返回一段时间，然后在短时间内开始阻塞每个调用。在什么情况下会引发此异常？
浏览 194提问于2016-01-15得票数 43
回答已采纳
奇怪的问题。
当我使用从com端口读取数据时，如果数据到达，则在第一个调用上只读取一个字节，忽略了count参数和超时内可用的字节数。所有进一步的读数都很好，只有第一个有问题。当接收到指定数量的数据或超时过期时，它将返回。看起来，只有当接收到零字节时，TimeoutException才会被抛出。如果在读取请求的数据量之前超时已过期</em
浏览 0提问于2014-07-10得票数 2
回答已采纳
我有一个由8个分区组成的kafka主题，它是从单个用户那里订阅的，我为消费者提供了唯一的消费群体。现在，我只尝试使用来自所有分区的最近消息(在我的例子中，在当前时间之前3分钟)。如果offsetForTimes只使用一个/两个分区，那么如何轮询单个用户的所有分区最近记录？
编辑:我使用的是卡夫卡集群。
浏览 2提问于2019-12-05得票数 1
Kafka版本: 0.10.2.1，org.apache.kafka.common.errors.TimeoutException: Expiring 10 record(
浏览 6提问于2017-10-15得票数 29
1回答
线性执行器有一个API，它提供了使用PySerial读取和写入硬件的函数，这些就是我用来尝试和执行器交谈的函数。它可以写入硬件OK，并且线性执行器根据需要扩展/撤回，但是将位置反馈从硬件结果读取到超时&如果我增加超时值或将serial.read()更改为serial.read(1) (通过直接更改API中的代码)相反，传递给执行器的位置值是硬编码的。这个函数使用来
浏览 10提问于2022-03-22得票数 -2
回答已采纳
在创建多个使用者(使用Kafka0.9javaAPI)并启动每个线程之后，我将得到以下异常at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:288:303)
at org.apache.k
浏览 0提问于2016-02-26得票数 8
3回答
我有一个基于Qt的TCP客户端和服务器，使用QTcpServer和QTcpSocket类进行通信。服务器端使用Qt 5.3.1编译，客户端使用Qt 4.8.1编译。这样做是因为客户端是使用运行在Ubuntu 12.04上的Qt 4.8.1的框架的一部分。
由于我使用的类在两个Qt版本中都可用，所以我认为这不会造成问题。然而，我的客户机有一些奇怪的问题，它不能从服务器接收数据！我检查了服务器端，数据是从服务器发送的，我
浏览 6提问于2014-08-14得票数 0
1回答
Pattern.compile(regex), listener); return consumer;} 我的轮询循环在代码中的不同位置("Consumer is shutting down", e); consumer.close(); } 当我运行代码并使用此函
浏览 21提问于2020-07-09得票数 2
回答已采纳
2回答
当使用从控制台生产者产生的记录时，它工作得很好。我有一个场景，在处理所有数据之前，可能会收到记录。当记录被流应用程序不匹配处理时，它们会移动到死信主题，而不是继续往下流。当我们到达结束偏移量时，使用者通过KafkaConsumer#pause暂停该分区，当
浏览 0提问于2019-02-11得票数 5
回答已采纳
2回答
我使用5台机器(kafka版本2.3.0)构建了一个集群( kafka version 2.3.0)，它的分区为0，数据副本为3。当我使用kafka-客户端api时，我继续输出异常:在分区测试中，偏移提交失败-0，偏移量1:请求超时。但是这个主题读和写消息是可以的。关闭组协调器所在的机器。在组协调器切换到另一台计算机后，错误仍然存在。
我
浏览 10提问于2019-11-03得票数 1
我试图了解两个汇流消费者配置下面的默认值是如何一起工作的。例如，假设对于一个消费者，消费者每3,000 ms发送一次心跳，我的第一次投票发生在时间戳t1，第二次投票发生在t1 + 20,00 ms。或者它会正常工作，因为消费者确实按照预期的时间戳发送了心跳吗？
浏览 0提问于2019-10-22得票数 3
回答已采纳
/bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts[2014/bin/kafka-topics.sh --zookeeper localhost:2181 --list那这是什么意思？
浏览 3提问于2014-06-01得票数 84
回答已采纳
我正在使用Phonegap为Android构建一个移动应用程序，该应用程序使用地理定位和FourSquare的API。我想让应用程序离线运行，所以我求助于在getCurrentPosition方法中使用onError方法。神秘的是，这只在某些情况下有效。我尝试了所有可能的方法，包括使用设备的无线和/或GPS开关进行测试，结果都是一样的:有时调用onError方法，而有时不调用。该应用程序在在线时运行良好。我已经包含了javascriptcod
浏览 0提问于2013-07-23得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
