3回答
我正在尝试从本地机器连接到Kafka：kafkaParams.setPropertykafkaParams.setProperty("group.id", "group_id")非常好，但是我的BROKER_<em
浏览 155提问于2016-07-26得票数 0
我有Flink (任务经理和作业经理)和Kafka作为码头图像运行在我的mac上。
我创建了一个Flink作业并部署了它。这项工作使用FlinkKafkaConsumer和FlinkKafkaProducer，应该从卡夫卡消费，并生产出卡夫卡。看起来我使用的"bootstrap.servers" (kafka:9092)对Flink没有意义，Flink失败的原因
浏览 1提问于2021-11-23得票数 1
回答已采纳
我正在努力学习Flink，Docker和Kafka，所以我正在尝试设置一个简单的虚拟设置，让Flink和Kafka从不同的容器中进行通信。我在一个虚拟机上运行了Kafka和Flink，所以这里唯一相关的部分可能是引导服务器。" flink:latest taskmanager启动任务管理器
目前，我启动kafka的对接
浏览 1提问于2021-09-10得票数 1
回答已采纳
我正在尝试运行正式的"Kafka010Example.scala"，但是它并没有像预期的那样从输入主题中读取和写入输出。我错过了什么或者做错了什么？任何帮助或暗示都很感激。latest
$ docker exec -it 26d1cfced4cb /bin/bash
$ /opt/kafka_2.11-0.10.1.01 --partitions 1 --topic te
浏览 0提问于2017-10-14得票数 1
我是新来码头的。我想对kafka进行容器化，并向其中添加一个集群，比如MyCluster，然后在kafka服务器启动后立即向集群添加4个主题，例如topic_a、topic_b、topic_c和topic_d。我尝试了以下docker-compose.yml，我能够启动容器化的kafka服务器和kafka管理器，但我不能以编程方式创建集群/主题。请帮帮我！1 --topic topic_a
/opt/k
浏览 34提问于2020-10-23得票数 2
我正在尝试设置一个本地的梁运行程序，以便更容易地测试/开发。我希望允许测试python管道，它在我的mac上本地使用kafka。下面是我当前对整个框架的计划如下：这是我现在的docker-compose zookeeper: ports:
- "218
浏览 23提问于2022-11-14得票数 1
据我所知，处理Kafka流的状态在内存、磁盘或Kafka主题中都是本地的，因为所有的输入数据都来自一个分区，其中所有的消息都是由一个定义的值键控的。大多数情况下，计算可以在不知道其他处理器的状态的情况下完成。如果是这样的话，您有另一个Streams实例来计算结果。如图所示：Flink到底在哪里存储它的状态？Flink是否也可以在本地存储状态，或者总是将它们发布到所有实例(任务)？是否可以
浏览 0提问于2019-02-10得票数 3
我编写了Kafka流应用程序，我想将它部署到Kafka集群上。，我构建了一个jar文件并使用以下命令运行它：它运行正常，但作业运行在我在命令上运行的机器上！那么，我的问题是如何
浏览 1提问于2017-12-01得票数 5
回答已采纳
1回答
我正在尝试将Apache Kafka 2.11-0.10.0.0与Apache Flink 1.1.2集成。我正在使用scala-shell对其进行测试，并得到以下错误。下面是我在shell中运行的代码 import org.apache.flink.streaming.util.serialization.SimpleStringSchema方法代替FlinkKafkaCons
浏览 13提问于2016-09-15得票数 1
回答已采纳
2回答
我正在尝试使用Apache Flink消费事件。代码非常基础，试图通过空格连接主题分词，并将其打印到控制台。Kafka版本是0.9。import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.streaming.connectors.kafka</em
浏览 36提问于2019-08-20得票数 3
回答已采纳
编译后的.jar通过flink -c <entry point> <path to .jar>提交给flink，并命中以下错误：
其他我可能会错过的东西？我应该使用风暴KafkaSpout，还是使用flink 编写自
浏览 25提问于2015-10-25得票数 2
回答已采纳
1回答
我有一个使用kafka-net (James Roland)的C#项目。我有一个docker撰写文件，它在我的笔记本电脑上运行kafka。我可以从windows命令行使用kafka实例生成和使用消息，而不会出现问题。KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181 - app-tier -/
浏览 1提问于2021-10-21得票数 1
我以为所有的Java依赖都是和pip install apache-flink一起安装的 以上错误发生在该行上： kafka_consumer = FlinkKafkaConsumer( deserialization_schema=deserialization_schema, 'bootstrap.servers': KAFKA_BOOTSTRAP_SERVERS}) 根据错误，我是否需要
浏览 252提问于2021-09-26得票数 0
有没有办法使用cassandra进行Apache kafta ACL身份验证？到目前为止，我还没有看到任何关于这方面的例子。
浏览 0提问于2016-05-24得票数 0
我试图用Flink的KafkaSource运行一个简单的测试程序。我使用的方法如下：
import org.apache.flink.streaming.api.
浏览 3提问于2015-07-15得票数 5
1回答
我正在运行卡夫卡和Flink作为码头集装箱在我的mac。 hostname: broker depends_on:
-
浏览 2提问于2021-11-24得票数 0
回答已采纳
有没有人可以在Scala中分享Flink Kafka的工作示例(主要是从Kafka接收消息)？我知道在Spark中有一个的例子。我只需要在Flink中打印出Kafka消息。这将是非常有帮助的。
浏览 2提问于2015-07-16得票数 6
2回答
我目前正在使用Kafka和Flink，我让kafka在我本地的PC上运行，我创建了一个正在使用的主题。Desktop\kafka\bin\windows>kafka-console-consumer.bat --zookeeper本地主机:2181 -topic测试有没有办法进一步了解这条消息的细节我查看了kafka文档，但没有找到有关此主题的内容
浏览 2提问于2016-12-31得票数 43
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
