我是Kafka的新手，正在尝试使用AdminClient应用程序接口来管理我本地机器上运行的Kafka服务器。我将其设置为与Kafka文档的部分完全相同。唯一的区别是我没有创建任何主题。props.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG,
浏览 49提问于2018-07-13得票数 14
private val adminprops = new Properties() private val admin = AdminClient.create(adminprops)
val result = admin.listTopics.names.get.contains(topicN
浏览 12提问于2022-02-11得票数 1
1回答
我们希望永久删除主题如下删除磁盘上的目录将主题从动物园管理员中删除：把动物园的cli弄成：现在我们删除这些主题
rmr /config
浏览 1提问于2019-08-25得票数 0
我试图在我的本地机器上用java 11安装kafka 3.1.0。但是，在列出现有主题的同时，我得到了超时异常。步骤如下：
C：\kafka_2.
浏览 4提问于2022-02-20得票数 0
回答已采纳
我正试图从一个kafka节点执行命令。我们有3个Kafka代理节点。9092配置为SASL_PLAINTEXT。我一直在犯错误。你能帮我解决这个问题吗？[2020-05-14 09:44:21,874] DEBUG [AdminClient clientId=adminclient-1] Initiating AP
浏览 15提问于2020-05-14得票数 1
回答已采纳
如何使用java为kafka 0.10.1.x创建无zookeeper依赖的kafka topic？我见过创建主题的线程，但它使用zookeeper，zk客户端等。我想只使用java，没有scala依赖，因为kafka 0.10已经不使用zookeeper。
浏览 1提问于2017-12-11得票数 0
4回答
- zookeeper KAFKA_BROKER_ID: 1 KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
KAFKA_ADVERTISED_
浏览 80提问于2018-12-03得票数 26
回答已采纳
bootstrap.servers", "localhost:9092"); adminProperties.put(AdminClientConfig.DEFAULT_API
浏览 9提问于2020-11-09得票数 4
我使用Kafka创建了Kafka消费者代码，我能够成功地从Kafka主题中获取记录，并能够处理这些记录。我在下面的应用程序日志中看到了显示为"Node -2断开连接“的错误，但是仍然没有影响，kafka streams API正在成功地从kafka主题中获取事务。clientId=consumer-5322b972-1ef9-4976-b7fa-39a934374757-admin org.apache.kafka.clients.NetworkClient
浏览 4提问于2022-09-23得票数 0
在开始生产和消费作业之前，我要确保kafka服务器是否正在运行。它在windows环境下，这是我的kafka服务器在eclipse中的代码……properties.setPropertyString> option = Option.empty();KafkaServer kafka= new KafkaServer(config, n
浏览 4提问于2016-06-20得票数 64
我对使用AdminClient createTopics创建的主题有异议。在我的应用程序中，我有以下顺序：
adminClient
.createTopics(Collections.singleton(new NewTopic(targetTopic, 1, (short) 1)))当AdminClie
浏览 0提问于2018-12-24得票数 5
回答已采纳
2回答
我不知道我是不是错过了一些配置
ports:environment: KAFKA_ZOOKEEPER_CONNECT: XXX:12181/secrets:/et
浏览 2提问于2019-06-25得票数 1
回答已采纳
异步调用不使用回调()，程序等待send()完成，并且不完整地执行下一行。void onCompletion(RecordMetadata metadata, Exception exception) {
“无法建立到节点-1的连接。代理可能不可用。”但是我希望，由于Asynchr
浏览 0提问于2019-02-01得票数 0
1回答
为了连接到Kafka集群，我获得了一组具有名称和端口的引导服务器：s2:9092卡夫卡和动物园管理员正在运行实例s4。我引用了上述引导服务器定义，因为我试图理解卡夫卡代理s1、s2、s3和运行在s4上的动物园管理员kafka之间的关系。
为了连接到Kafka集群，我将代理设置为's1，s1，s3‘的CSV列表。负责安装Kafka盒的个人不再可用，我不知道这种配置是如何工作的。我已经搜索了代理程序s1、s2、s3在s4上的配置引用，但似乎没有任何配置。在设置和配置Kaf
浏览 3提问于2020-12-05得票数 0
回答已采纳
我正在使用Flink DataStream API中的DataStream类来实现像用例这样的超时。场景如下:我有一个输入kafka主题和一个输出Kafka主题，一个服务从输入主题读取它(在可变的时间内)，然后在输出kafka主题中发布响应。现在要实现超时(必须使用Flink datastream )，我有一个从kafka输入主题读取的FlinkKafkaConsumer，以及从kafka输出主题读取的另一个FlinkKafkaConsumer我正在连
浏览 1提问于2020-09-15得票数 0
回答已采纳
(org.apache.kafka.clients.NetworkClient)[2022-03-14 10:24:18,206] WARN [AdminClient clientId=adminclient(org.apache.kafka.clients.N
浏览 16提问于2022-03-14得票数 1
问:我需要为节点分配设置2小时的时间，一旦节点在时间限制内分配，构建应该继续，如果节点没有在时间范围内分配，构建应该放弃。我试过使用超时函数，但在这些函数中，如果分配了节点，一旦达到时间限制，构建就会在执行过程中中止。System.currentTimeMillis()node('Slave_Node') {
/
浏览 34提问于2020-05-19得票数 2
回答已采纳
1回答
我试图使用Apache通过一个流浪机器运行一个简单的Kafka消费者程序。当程序试图调用.poll(100)方法时，它会被困在for循环之前。props.put(&q
浏览 0提问于2019-06-10得票数 3
当尝试使用--bootstrap-server，创建主题时，我得到了异常“执行主题命令时的错误:超时等待节点”:-但是，以下工作正常，使用--动物园管理员 :-
kafka-topics --zookeeperlocalhost:2181--topic boottopic --replication-fac
浏览 4提问于2020-05-07得票数 0
卡夫卡和动物园管理员在同一个服务器上，有多个节点。问题是，卡夫卡将不会启动，直到所有动物园管理员节点可用。否则，我将得到一个错误，比如“Kafka启动期间的致命错误”和“处于状态时超时等待连接:连接”，即使其他Zookeeper节点已经启动。这使得独立地编写每个节点的启动脚本变得很困难，因为一个节点上的启动脚本依赖于其他节点的状态。
第一:这是预期的行为还是我做错了什么？假设我在动物园管理员集群中有3个节点；所有3个
浏览 5提问于2019-12-21得票数 0
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
