1回答
我已经尝试将引导属性设置为：获取错误:在身份验证期间终止到节点-1 (/xx.xx:9092)的连接。这可能是由于以下任何原因造成的：(1)身份验证失败是由于代理的凭据无效，代理的年龄超过1.0.0；(2)防火墙阻塞Kafka TLS通信量(例如，它可能只允许HTTPS通信)；(3)瞬态网络问题。spring.kafka.properties.security.protocol=SASL_SSL
引发的抛出: java.lang.Ille
浏览 2提问于2020-03-02得票数 1
我想使用Apache Spark Structured Streaming和Kafka，Spark Structured Streaming支持Kafka 0.10及更高版本，我的Kafka集群使用kafka我想将当前kafka 0.8.2.1集群中的一些主题复制到基于2.2.0的新Kafka集群中。为此，我尝试在Kafka 2.2.0集群上使用kafka-console-cons
浏览 17提问于2019-05-23得票数 1
假设我有3个复制因子为3的分区。现在我所理解的是，它们都必须连接到同一个zookeeper。好的，如果他们因为网络问题而不能呢？当网络再次可用时，复制是否会继续？
浏览 36提问于2018-03-05得票数 1
回答已采纳
value.converter": "io.confluent.connect.avro.AvroConverter", "internal.value.converter": "org.apache.kafka.co
浏览 0提问于2021-10-08得票数 0
回答已采纳
在创建KafkaProducer时，我们传入如下属性
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, IKafkaConstants.KAFKA_BROKERS
浏览 3提问于2018-08-03得票数 2
我需要使用kafka stream 2.2库中的功能，然而，我的底层kafka broker版本不是2.2。可以使用kafka stream 2.2版本的库来对抗kafka broker 2.12-1.1.1吗？
浏览 1提问于2019-06-13得票数 1
我们公司的Kafka是融合的Kafka，它是Kerberized的。我能够通过Kafka API编写生产者和消费者，因为我们知道代理和密钥表文件。建议使用Kafka-Connect，但由于它是多租户集群，Ops团队可能无法提供直接访问，甚至无法运行插件安装命令。我们有自己的托管虚拟机，可以在其中部署应用程序实例。Ques -有没有可能通过在我们的VM上安装连接器插件而不是在Confluent Kafka上安装连接器插件来在分布式模式下运行Kafka-Connect？更新
浏览 5提问于2020-06-18得票数 0
然而，在"WikipediaFeed“对象中，我试图从另一个Kafka代理获取数据，而不是从启动Hello-Samza网格时运行的Kafka代理获取数据。我是否必须在"WikipediaFeed“对象中创建一个线程安全的Kafka消费者来使用来自不同Kafka集群的数据，还是有其他我看不到的方式？谢谢
浏览 6提问于2017-09-22得票数 0
我安装合流，它有自己的卡夫卡。我必须更改哪个.properties or whatelse文件以使其看起来不同。
浏览 0提问于2020-04-15得票数 0
回答已采纳
使用kafka处理器API(而不是DSL)读取源主题并将其写入目标主题它适用于单个kafka集群设置(也就是说，如果源主题和目标主题驻留在同一集群上)，但是当源主题和目标主题驻留在不同的kafka集群上时sourceProcessorProps = new Properties();
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "SourceStreamProcessor"); // Kaf
浏览 1提问于2020-06-18得票数 0
2回答
我试过了Quickstart教程，但是没有关于如何设置多服务器集群的说明。我的脚步1)bin/zookeeper-server-start.sh config/zookeeper.properties3)bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor1 --partit
浏览 6提问于2017-04-03得票数 1
我正在将Kafka连接器从ECS集群迁移到运行在Kubernetes上的新集群。通过删除Postgres源连接器并在精确的复制槽上重新创建它们，我成功地迁移了Postgres源连接器。他们一直在为同一个卡夫卡集群中的同一个主题写作。旧集群中的S3连接器继续读取这些数据，并将记录写入S3。一切照常运作。但是现在要移动AWS s3接收器连接器，我首先在新集群中创建了一个非关键的s3连接器，其名称与旧集群中的名称相同。为了避免丢失数据，我打算在删除旧的数据之前等几分钟。因此，
浏览 8提问于2022-05-16得票数 0
回答已采纳
1回答
我们在两个独立的DC中运行两个Kafka集群。我们的整体传入流量是在这两个区议会之间分配的。我读过一条卡夫卡流是不可能的。有什么方法可以用另一个卡夫卡流从DC1读取并写入DC2卡夫卡集群吗？
浏览 1提问于2019-11-15得票数 0
回答已采纳
1回答
我正在通过SSL移动我们所有的Kafka流量。我们在每个区域都有两个集群。除了一个集群之外，所有区域和所有集群都可以在SSL上正常工作。当通过明文连接对这个集群执行kafkacat -L时，它会列出所有代理、主题和分区，并显示每个分区的领导者：
# kafkacat -b kafka-cluster1-kafka-brokers.domain.cominter.broker.protocol和与动物园管理员集群
浏览 4提问于2021-08-09得票数 1
有没有人可以和我分享一下用两个kafka broker和zookeeper集群创建kafka集群的yaml文件。我是kubernetes新手。
浏览 5提问于2019-05-10得票数 0
我有spring引导应用程序，它连接到我的kafka集群。应用程序(如kafka客户端)使用SASL身份验证，在初始化kafka生产者和使用者之前，我通过System.setProperty()指定了JAAS配置。它很好地工作在单卡夫卡集群设置。kafka_client_jaas.conf org.apache.kafka.common.security.plain.PlainLoginModule required");
浏览 3提问于2020-07-22得票数 2
回答已采纳
我在我的mac上的minikube k8集群的Pod上运行了一个landoop kafka镜像。我有两个不同的服务来公开用于模式注册的端口8081和用于代理的端口9092。我已经在我的NodePort服务中映射了端口8081 -> 30081和9092 -> 30092，以便我可以从集群外部访问它。但是，当我尝试运行控制台消费者或我的消费者应用程序时，Kafka从不消费消息。1)不能在k8集群之外通过上述方式访问k8集群外的Kafka吗?如果是这样，我是不是
浏览 86提问于2018-02-13得票数 3
2回答
当我尝试同时向2个Kafka节点发送数据日志时，Filebeat出现问题output.kafka: hostsxxx.xx:9092", "192.168.zzz.zz:9092" ] timeout: 30s两个kafka我的意思是只有Kafka节点192.16
浏览 2提问于2018-11-17得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
