当前位置：首页 > news >正文

kafka生产者指定ip

news 2025/12/24 1:04:41

kafka生产者指定ip

最近工作中遇到一个问题，记录一下，需求中要求往kafka上推送信息。本来是个很简单的需求，但是踩了一个坑。

我通过spring boot集成了kafka写了一个生产者，客户那边给我三个节点的ip，然后我也没多想就配置上来了，但是实际上客户的集群中搞了10个主机部署了kafka，然后我就无了。我只配置了给我的三个节点的hosts，后端就开始疯狂报错hosts unknow的异常。

spring:kafka:bootstrap-servers: ip1:9092,ip2:9092,ip3:9092

这里需要讲一下kafka的机制，当你使用Kafka生产者发送消息时，Kafka会根据负载均衡策略在所有可用的Kafka节点之间进行分配，以确保负载均衡和容错。所以，我的生产者可能会向配置的主机以外的主机发送消息。

如果要限制消息发送到特定的主机，可以使用spring.kafka.producer.bootstrap-servers属性来指定要使用的Kafka节点的主机地址，而不是使用spring.kafka.bootstrap-servers属性。

spring:kafka:producer:bootstrap-servers: ip1:9092,ip2:9092,ip3:9092

kafka生产者指定ip

kafka生产者指定ip 最近工作中遇到一个问题，记录一下，需求中要求往kafka上推送信息。本来是个很简单的需求，但是踩了一个坑。我通过spring boot集成了kafka写了一个生产者，客户那边给我三个节点的ip，然后我也没多想…...

编程日记 2023/8/5 10:19:37

select * from Teacher limit 10 连接字符串配置MysqlConfig.py class MysqlConfig:HOST 192.168.56.210PORT 3306USER rootPASSWORD 1qaz0987654321DBStudentDBCHARSET utf8封装增删改查MysqlConnection.py Author: tkhywang 2810248865qq.com Date: 2023-06-19 15:44:48 Las…...

编程日记 2023/8/5 10:18:36

Flink正常消费一段时间后，大量反压，看着像卡住了，但又没有报错。

文章目录前言一、原因分析二、解决方案前言前面我也有提到，发现flink运行一段时间后，不再继续消费的问题。这个问题困扰了我非常久，一开始也很迷茫。又因为比较忙，所以一直没有时间能够去寻找答案，只是通过每天重启…...

编程日记 2023/8/5 10:17:34

软件测试需求分析的常用方法

软件测试需求分析时，应要求产品人员对需求进行讲解，并使用相对应的方法进行科学分析，否则无法保障软件测试的完整性和科学性，从而造成在项目中后期Bug频出、风险增大等问题。而常用的测试需求分析的方法： 1、功能分解…...

编程日记 2023/8/5 10:16:30

数据结构10 -查找_树表查找

创建二叉搜索树二叉搜索树二叉搜索树是有数值的了，二叉搜索树是一个有序树。若它的左子树不空，则左子树上所有结点的值均小于它的根结点的值； 若它的右子树不空，则右子树上所有结点的值均大于它的根结点的值； 它…...

编程日记 2023/8/5 10:15:28

第126天：内网安全-隧道技术SSHDNSICMPSMB上线通讯LinuxMac

知识点 #知识点： 1、入站规则不出网上线方案 2、出站规则不出网上线方案 3、隧道技术-SMB&ICMP&DNS&SSH 4、控制上线-Linux&Mac&IOS&Android-连接方向：正向&反向（基础课程有讲过） -内网穿透&#xf…...

编程日记 2023/8/5 10:14:26

开发一个饲料商城小程序需要多少钱

随着宠物行业的蓬勃发展，饲料商城小程序作为一个重要的销售渠道，吸引了越来越多的投资者。那么，开发一套饲料商城小程序需要多少钱呢？本文将为您详细解答。首先，开发一套饲料商城小程序的价格受到多个因素的影响&…...

编程日记 2023/8/5 10:13:24

Emacs之set-face-attribute与font-lock-add-keywords用法区别(一百二十八)

简介： CSDN博客专家，专注Android/Linux系统，分享多mic语音方案、音视频、编解码等技术，与大家一起成长！ 优质专栏：Audio工程师进阶系列【原创干货持续更新中……】🚀 人生格言： 人生…...

编程日记 2023/8/5 10:12:22

JavaScript高阶函数和闭包

在JavaScript编程中，高阶函数和闭包是两个重要而又常见的概念。它们是函数式编程的重要组成部分，可以让我们的代码更加灵活、简洁和高效。本文将详细解释高阶函数和闭包的概念、用法以及它们在JavaScript中的重要性。高阶函数 1. 什么是高阶函数&…...

编程日记 2023/8/5 10:11:21

私有化部署企业IM即时通讯：提升效率、防止泄密、高效协同办公

随着科技的飞速发展和智能手机的普及，即时通讯（IM）应用在我们的生活和工作中变得越来越重要。在企业中，IM已成为员工之间交流沟通的主要方式之一。然而，对于大多数企业来说，选择私有化部署企业IM即时通讯软…...

编程日记 2023/8/5 10:10:20

react ant icon的简单使用

refer: 快速上手 - Ant Design 1.引入ant npm install antd --save 2.在页面引用： import { StarOutlined } from ant-design/icons; 如果想要引入多个icon，可以这样书写： import { UserOutlined, MailOutlined, PieChartOutlined } fr…...

编程日记 2023/8/5 10:09:19

用Rust实现23种设计模式之原型模式

在 Rust 中，原型模式可以通过实现 Clone trait 来实现。原型模式是一种创建型设计模式，它允许通过复制现有对象来创建新对象，而无需显式地使用构造函数。下面是一个使用 Rust 实现原型模式的示例，带有详细的代码注释和说明&#x…...

编程日记 2023/8/5 10:08:18

visual studio 2022 编译时出现MSB3721问题

cuda1C:\code\SSR\Impl\Dev\gE\cO\G.Common.XrayRegistration_nc>“C:\Program Files\NVIDIA GPU Computing Toolkit\CUDA\v11.7\bin\nvcc.exe” -gencodearchcompute_86,code“sm_86,compute_86” --use-local-env -ccbin “C:\Program Files\Microsoft Visual Studio\2022…...

编程日记 2023/8/5 10:07:17

Android 获取网络连接状态新方法

一. 问题背景 Android12上，有的app模块判断当前网络的类型和连接状态时，还是使用的旧的API，导致返回的结果不准确，影响代码逻辑判断，本篇文章就这一问题，整理一下判断网络类型和连接状态的新方法。二. 原因…...

编程日记 2023/8/5 10:06:16

可缝合神经网络

文章目录 Stitchable Neural Networks摘要本文方法实验结果 Stitchable Neural Networks 摘要包含大量强大的预训练模型族(如ResNet/DeiT)的model zoo已经达到了前所未有的范围，这对深度学习的成功有重要贡献。由于每个模型族都由具有不同尺度的预训练模型(例如&…...

编程日记 2023/8/5 10:05:14

Android优化篇|网络预连接

作者：苍耳叔叔一个示例前后分别去请求同一个域名下的接口，通过 Charles 抓包，可以看到 Timing 下面的时间： 第二次请求时，DNS、Connect 和 TLS Handshake 部分都是 -，说明没有这部分的耗时，…...

编程日记 2023/8/5 10:04:13

pyspark使用XGboost训练模型实例

遇到一个还不错的使用Xgboost训练模型的githubhttps://github.com/MachineLP/Spark-/tree/master/pyspark-xgboost 1、这是一个跑通的代码实例，使用的是泰坦尼克生还数据，分类模型。这里使用了Pipeline来封装特征处理和模型训练步骤，保存为…...

编程日记 2023/8/5 10:03:12

完整模型的训练套路

从心所欲不逾矩天大地大皆可去一、官方模型的初使用使用VGG16模型 VGG模型使用代码示例： import torchvision.models from torch import nndataset torchvision.datasets.CIFAR10(/cifar10, False, transformtorchvision.transforms.ToTensor())vgg16_true …...

编程日记 2023/8/5 10:02:10

PtahDAO：全球首个DAO治理资产信托计划的金融平台

金融科技是当今世界最具创新力和影响力的领域之一，区块链技术作为金融科技的核心驱动力，正在颠覆传统的金融模式，为全球用户提供更加普惠、便捷、安全的金融服务。在这个变革的浪潮中，PtahDAO（普塔道）作为全…...

编程日记 2023/8/5 10:01:09

从零搭建一个react + electron项目

最近打算搭建一个react electron的项目，发现并不是那么傻瓜式于是记录一下自己的实践步骤通过create-react-app 创建react项目 npx create-react-app my-app 安装electron依赖 npm i electron -D暴露react项目的配置文件（这一步看自己需求&#xff0c…...

编程日记 2023/8/5 10:00:08

初学 pytest 记录

安装 pip install pytest用例可以是函数也可以是类中的方法 def test_func():print()class TestAdd: # def __init__(self): 在 pytest 中不可以使用__init__方法 # self.cc 12345 pytest.mark.api def test_str(self):res add(1, 2)assert res 12def test_int(self):r…...

编程新知 2025/12/15 0:46:10

Java 二维码

Java 二维码 **技术：**谷歌 ZXing 实现首先添加依赖 <dependency><groupId>com.google.zxing</groupId><artifactId>core</artifactId><version>3.5.1</version></dependency><de…...

编程新知 2025/9/6 16:22:45