跳转到内容
彼岸论坛

小天管理

管理员
  • 内容数

    16155
  • 注册日期

  • 最后上线

  • 得奖次数

    1

小天管理 发表的所有内容

  1. 佬们,请教个问题,我需要搭建一个单节点的 kafka 服务器,,根据官网的教程,我已经搭建好了,现在需要局域网的节点的能连 kafka 服务器,为了 kafka 服务器能局域网能访问,需要修改配置文件 ,修改内容如下 listeners=PLAINTEXT://0.0.0.0:9092 advertised.listeners=PLAINTEXT://192.168.5.155:9092 这样操作后,在本机上,创建话题,再使用生产者,和消费者没有问题。但是我在另一台服务器上使用 Python3 脚本模拟生产者,消费者就有问题。 下面是生产者脚本 from kafka3 import KafkaProducer import json 创建 Kafka Producer 实例 producer = KafkaProducer( bootstrap_servers=‘192.168.5.155:9092’, # Kafka 服务器的地址和端口 value_serializer=lambda v: json.dumps(v).encode(‘utf-8’) # 将消息序列化为 JSON 格式 ) 发送消息到 Kafka 的主题 producer.send(‘test-topic’, {‘key’: ‘value’}) # ‘my-topic’ 替换为你的实际主题名 确保所有消息都被发送 producer.flush() print(“消息发送成功”) 下面是消费者的脚本 from kafka3 import KafkaConsumer import json 创建 Kafka Consumer 实例 consumer = KafkaConsumer( ‘test-topic’, # 替换为你的实际主题名 bootstrap_servers=‘192.168.5.155:9092’, # Kafka 服务器的地址和端口 auto_offset_reset=‘earliest’, # 从最早的消息开始读取 enable_auto_commit=True, # 自动提交偏移量 group_id=‘my-group’, # 消费者组 ID value_deserializer=lambda x: json.loads(x.decode(‘utf-8’)) # 将消息反序列化为 JSON 格式 ) 消费消息 for message in consumer: print(f"接收到消息: {message.value}") 运行脚本报错了, Traceback (most recent call last): File “/root/python_code/writing.py”, line 5, in producer = KafkaProducer( File “/usr/local/lib/python3.10/dist-packages/kafka3/producer/kafka.py”, line 383, in init client = self.config[‘kafka_client’]( File “/usr/local/lib/python3.10/dist-packages/kafka3/client_async.py”, line 244, in init self.config[‘api_version’] = self.check_version(timeout=check_timeout) File “/usr/local/lib/python3.10/dist-packages/kafka3/client_async.py”, line 900, in check_version raise Errors.NoBrokersAvailable() kafka3.errors.NoBrokersAvailable: NoBrokersAvailable 想问哈各位哪里不对,脚本是用 chatgpt4 生成的,我在 192.168.5.111 上 ping 192.168.5.155 是通的,我试了 telnet 192.168.5.155 9092 不通,但我已经 关了防火墙,我查看了又有端口监听在 9092. 感谢各位大佬给我指点。
  2. 我的微信绑定的手机号是美国的(+1 ),然后 +1 xxx xxx xxxx 带上国家代码连起来刚好十一位,竟然跟某个微信绑定的 +86 手机号重了... 有个人加我微信说我在他们公司投了简历,我一脸懵,一看才知道那人的 +86 手机号和我 +1 手机号带上 1 之后完全一样... 我的微信测试下来通过 001 ,1 ,不要区号三种方式都能搜到,不知道遇到这种冲突的情况下微信是怎么处理的...
  3. systemd 日志总是被轮转,有什么办法可以解决吗? [root@localhost ~]# grep -v ^# /etc/systemd/journald.conf [Journal] [root@localhost ~]# [root@localhost ~]# journalctl --disk-usage Archived and active journals take up 184.0M on disk. [root@localhost ~]# [root@localhost ~]# systemctl status systemd-journald.service ● systemd-journald.service - Journal Service Loaded: loaded (/usr/lib/systemd/system/systemd-journald.service; static; vendor preset: disabled) Active: active (running) since Fri 2024-08-23 22:28:55 CST; 1 day 15h ago Docs: man:systemd-journald.service(8) man:journald.conf(5) Main PID: 610 (systemd-journal) Status: "Processing requests..." CGroup: /system.slice/systemd-journald.service └─610 /usr/lib/systemd/systemd-journald Warning: Journal has been rotated since unit was started. Log output is incomplete or unavailable. [root@localhost ~]# 出现这个 Warning: Journal has been rotated since unit was started. Log output is incomplete or unavailable. 网上搜了一下,redhat 说不用管它,但日志被轮转了会导致 journalctl 看不了系统日志。
  4. 2024macmini 据说会做的很小,会不会有厂商出一款 mac 皮笔记本,只有键盘和屏幕,预留 macmini 主板的位置,之后把 mini 主板拆掉,直接装进 mac 皮笔记本里,哈哈,再预留俩 m2 接口,上俩 8T 固态。
  5. Surge for Mac 5 人车 自用 1 剩余 4 车位,155 一人 跳车不退,换设备自行反激活 授权终身有效,如有新的版本,后续可与车友协商升级。拉微信群保持联系 WX:d3hpZF84OTQ2OTM5NDcwNDEy
  6. 明明开了自动更新的按钮,手机也长时间在有 wifi 的区域,但我似乎就没见它自动更新过,刚刚弹通知提示我的离线地图快过期了,打开一看上次更新是 3 周前。自从离线地图这个功能上线以来基本都是我偶尔自己点的更新或者它弹提示我之前的地图快过期了,我再手动更新,好奇它这个更新逻辑到底是怎样,多久更新一次?
  7. 自己做了一些手动调整( 30%)左右吧。主要是没有掌握好怎么描述构建目录结构应该如何生成。 数据获取,给他一段网站的 html 结构,让他使用写一段 jquery 获取结构中的名字和图片链接等信息,然后放入油猴脚本中。 做表格简直不要太简单,直接给个 json 让他输出表格或者 markdown 即可。 布局方面只要给出明确提示说明要移动端友好即可。 网址: https://randomkits.com/kit/random-pokemon-generator 准备后续用 AI 写更多的随机工具,试试效果。
  8. 这写入有点不正常吧 之前怀疑过 spotlight 和 swap ,关掉之后还这样,无语了 https://s21.ax1x.com/2024/08/25/pAFTnOO.png
  9. 现在有点依赖 gpt 了,问点东西太好使了
  10. https://www.bbc.com/news/articles/ckg2kz9kn93o Telegram chief executive Pavel Durov has been arrested by French police at an airport north of Paris. According to officials the 39-year-old had been arrested under a warrant for offences related to the popular messaging app. 抓捕原因与 Telegram 有关
  11. 我想用机场绕墙玩外服窝窝屎,但手上的机场都不支持 UDP 。想问问 V 友们都用的什么游戏加速方案?
  12. YABS 测试,如上图 cpu 跑分 GB5 ,ssd 读/写性能 itdog.cn 测试 ping 移动快乐ipv4,如上图 广移 13ms ,全国移动平均 49ms itdog.cn 测试 ping 移动快乐ipv6,如上图 广移 17ms ,全国移动平均 49ms Taier 测速,单线程 ipv4 ( vps 测速上传=本地家宽测下载="xx 速度",vps 测速下载=本地家宽测上传) 上海移动 616Mbps 杭州移动 655Mbps 广州移动 1874Mbps (单线程 ipv4 突破 G 口) Taier 测速,单线程 ipv6 ( vps 测速上传=本地家宽测下载="xx 速度",vps 测速下载=本地家宽测上传) 上海移动 576Mbps 杭州移动 666Mbps 广州移动 1218Mbps (单线程 ipv6 突破 G 口) 流媒体解锁,ipv4测试 原生解锁 ChatGPT 后边有实测图 流媒体解锁,ipv6测试 ipv4 实测解锁 ChatGPT 炭云 CoalCloud 香港 v2 移动快乐机 10T 流量/月 HK 解锁 chatGPT ,单线程突破 G 口 vps 型号:HKBGP LITE V2 Venti 10T 测试如图 配置: 1 核 cpu ,AMD EPYC 7C13 1g 内存 20g 硬盘 NVME 高速固态 5 Gbps 带宽 10T 流量/月 ipv4+ipv6 续费价格,145.33 元/年 到期时间,2025 年 8 月 20 明盘 266 ,包 push 联系,TG 与 WX 同号:brunuhville
  13. 8 月 11 日提了 2025 款宋 Plus DM-i 112KM 尊荣版,目前开起来比较满意。唯独就是价钱方面没谈下来,原价 15.58w 购买,+5100 多的保险。配件只送了原厂脚垫和太阳膜,另外后面可以申请当地的 1.2w 补贴,总体还行吧。 正题: 一、提车当天,车企销售就推荐了延保服务,只要 3790, 8 年或者 21w 公里内免费更换原厂配件。说的可玄乎了,这个补贴价只有当天有。结果今天(已经过去了半个月了)那个销售又给我打电话,问我要办一下吗,说价格还是 3790 。我说我先了解下,晚点联系你,就挂了电话。 说实话,价格还好,但是不知道是否存在什么猫腻以及各种隐藏条款。所以想问问大家,他们销售推荐的这些真的靠谱吗?你们有人有买吗?或者有买过的人是否有使用过他们的这个延保服务,过程怎么样? 二、此外,贴太阳膜的时候,销售也是各种推荐其他产品。 太阳膜是授权售后店贴的,店里的销售各种给你推销其他产品,让你换更好的其他膜,990 全套。我说免费的就挺好,不考虑其他的了,结果销售立刻把脸拉了下来。接着马上要开始贴膜了,另一个销售过来态度相对好很多,说送的太阳膜确实会影响视线,实在不行让我把主副驾驶的换了,后面的不换也行。最后又说前挡风才是最重要的,换个好点的会好很多。耐不住攻势,花了 550 换了前挡风和主副驾玻璃为更好的 N70 和 1520 (具体型号我也不懂,也看不出具体差别)。 三、然后就是电池护板。我问了下授权售后的销售,她说原厂护板的价格加电机的一共是 1280 ,后来我犹豫了就没换。贴完膜回家后我在海洋 app 上看了下,原厂电池护板只要 665 ! 最后,搞得我也很晕。说实话我向来对销售没有什么好感,尤其是那种明知道有坑还要骗你进来,可能这就是他们的使命吧。 你们怎么看?
  14. 自己有个线下实体店,平日里要做些电子版宣传海报,请问现在哪些 AI 可以通过自己的文字描述生成图片呢? chatgpt 好像是需要开 plus 才可以……
  15. 使用相机获取西瓜大小,形状,纹路,颜色,还可以获取敲打时的声音频率。这些特征应该足够了吧。 在引申一下,还可以用来帮助年轻人挑选各种瓜果蔬菜,肉蛋米面等
  16. 求 TG 账号的稳定来源,之前+86 的用了几个月,前两天跟别人私聊被封了,申诉了快两天没有解封 早上用 giffgaff 注册,只加了一个 archlinuxcn 的频道后就被封了。。。。
  17. 平时集显够了 想玩玩 随便买个显卡玩玩 要求不高
  18. 真的无误了,今天和老妈聊天,听了老妈聊我姐和她男朋友的事,我发现我姐就和网上那些集美一样样的。
  19. 每次转账,比特币的地址就要变,说是为了隐私,但是实际上也能找得到关联。 对隐私没啥用,反而还增加了复杂度
  20. 需求: 可以上传原图,并且能够配文 大厂产品,小产品害怕没几年跑路了 或者能够自建的应用,图片上传到 oss 中 主要用来记录一些日常,可以不用分享 目前在用是朋友圈仅自己可见,但图片时间久了就会模糊不清
  21. 这个帖子为啥被删除了? https://www.v2ex.com/t/1067571?p=1#reply3 管理员来解释下。 之前在 telegram 里 https://wx1.sinaimg.cn/mw690/0082MA3cgy1hszxi4cz5kj32ly12ydrt.jpg 怎么就去了水深火热里了呢 https://wx3.sinaimg.cn/orj360/0082MA3cgy1hszxi5yj3pj328i0w4ajk.jpg
  22. 工作职责 负责直播和短视频服务端,参与内容生态、营销权益、商业化等业务研发工作,提升直播系统性能和研发效率,保证高并发高可用 通过持续技术创新,驱动用户体验、直播成长、平台营收健康持续增长,并通过平台即使能力赋能各垂直行业 深入调研和关注大模型/多模态等方向前沿技术,探索视频生成、数字人直播等落地场景 职位要求 有扎实的编程基础、良好的编程风格和工作习惯 深入理解计算机系统,有良好的数据结构和算法基础 有高并发服务设计和实现经验,对分布式系统有深入理解 熟悉 Mysql 、Nosql 、消息队列队列等中间件 对软件产品有强烈的责任心,具备良好的沟通能力和优秀的团队协作能力 简历投递 feiyang21687@gmail.com
×
×
  • 创建新的...