• nginx可以转发telegraf发送给kafka的数据吗?


    关注 码龄 粉丝数 原力等级 -- 被采纳 被点赞 采纳率 破晓·强袭 2024-03-27 21:56 采纳率: 0% 浏览 8 首页/ PHP / nginx可以转发telegraf发送给kafka的数据吗? nginxkafka nginx可以转发telegraf发送给kafka的数据吗?外网有一台服务器A使用telegraf采集服务器数据,通过output.kafka发送数据,有一个部署了nginx的服务器B用来转发A的数据到内网服务器C的kafka上,有一个内网服务器C用来接受nginx服务器转发的数据。请问服务器A产生的数据是否可以通过nginx服务器转发给内网的服务器上 收起 写回答 好问题 0 提建议 追加酬金 关注问题 微信扫一扫 点击复制链接 分享 邀请回答 编辑 收藏 删除 结题 收藏 举报 追加酬金 (90%的用户在追加酬金后获得了解决方案) 当前问题酬金 ¥ 0 (可追加 ¥500) ¥ 15¥ 20¥ 50¥ 100¥ 200 支付方式 扫码支付 二维码出错 点击刷新 支付金额 15 元 提供问题酬金的用户不参与问题酬金结算和分配 支付即为同意 《付费问题酬金结算规则》 结题 再想想 删除 再等等

    2条回答 默认 最新

    • 专家-皆知 2024-03-27 21:56
      关注

      引自免费微信小程序:皆我百晓生

      是的,Nginx可以作为反向代理服务器,将来自Telegraf的数据转发到内部的Kafka服务器。这种情况下,Nginx充当了一个数据传输的中继,将Telegraf收集到的数据传递给Kafka。

      以下是一个简单的示例,展示了如何使用Nginx作为反向代理来转发Telegraf发送的数据到Kafka:

      1. 在Nginx配置文件中,创建一个新的server块,用于监听Telegraf的输出并将其转发到Kafka。例如:
      server {
          listen 9092;
          server_name server-b.example.com;
      
          location /telegraf {
              proxy_pass http://telegraf-server:9092;
              proxy_set_header Host $host;
              proxy_set_header X-Real-IP $remote_addr;
              proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
          }
      }
      

      在这个示例中,Nginx监听9092端口,并将来自Telegraf的请求转发到本地的Kafka服务器。proxy_pass指令指定了Telegraf服务器的地址和端口。proxy_set_header指令用于将请求头信息传递给Telegraf服务器。

      1. 在Nginx配置文件中,创建另一个server块,用于监听Kafka的输入并将其转发到内网服务器C。例如:
      server {
          listen 9092;
          server_name server-c.example.com;
      
          location /kafka {
              proxy_pass http://server-c.example.com:9092;
              proxy_set_header Host $host;
              proxy_set_header X-Real-IP $remote_addr;
              proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
          }
      }
      

      在这个示例中,Nginx监听9092端口,并将来自Kafka的请求转发到本地的内网服务器C。proxy_pass指令指定了Kafka服务器的地址和端口。proxy_set_header指令用于将请求头信息传递给Kafka服务器。

      1. 在Nginx配置文件中,将两个server块合并为一个。例如:
      server {
          listen 9092;
          server_name server-b.example.com;
      
          location /telegraf {
              proxy_pass http://telegraf-server:9092;
              proxy_set_header Host $host;
              proxy_set_header X-Real-IP $remote_addr;
              proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
          }
      
          location /kafka {
              proxy_pass http://server-c.example.com:9092;
              proxy_set_header Host $host;
              proxy_set_header X-Real-IP $remote_addr;
              proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
          }
      }
      

      现在,Telegraf产生的数据将被Nginx转发到Kafka,然后Kafka将数据转发到内网服务器C。

      请注意,这只是一个简单的示例,实际的配置可能需要根据您的具体需求进行调整。例如,您可能需要设置身份验证和授权,以及错误处理和日志记录等。

      展开全部

      评论 编辑记录
    • 码农阿豪 Java领域优质创作者 2024-03-27 21:56
      关注
      让阿豪来帮你解答,本回答参考chatgpt3.5编写提供,如果还有疑问可以评论或留言
      可以。 Nginx可以通过配置proxy_pass将请求转发到内网服务器C的kafka上。具体配置如下: 在nginx的配置文件中添加以下server块:
      server {
          listen 80;
          server_name serverB.com;
          
          location / {
              proxy_pass http://serverC:9092;
              proxy_set_header Host $host;
          }
      }
      

      其中,serverB.com是nginx所在的服务器的域名或IP地址,serverC是内网服务器C的域名或IP地址,9092是kafka的端口号。 上述配置将会把来自服务器A的数据请求转发到内网服务器C上。 如果需要使用https,可以参考以下配置:

      server {
          listen 443 ssl;
          server_name serverB.com;
          ssl_certificate /path/to/server.crt;
          ssl_certificate_key /path/to/server.key;
          location / {
              proxy_pass https://serverC:9092;
              proxy_set_header Host $host;
          }
      }
      

      这里使用ssl连接,需要指定证书和密钥的路径。 实际上,nginx除了转发HTTP和HTTPS请求外,还可以转发TCP和UDP请求,因此也可以将telegraf发送给kafka数据包含在TCP请求中进行转发。代码示例如下:

      stream {
          upstream kafka {
              server serverC:9092;
          }
          server {
              listen 8888;
              proxy_pass kafka;
          }
      }
      

      这里使用stream模块配置,将监听8888端口的TCP请求转发到kafka服务器。

      展开全部

      评论
    编辑
    预览

    报告相同问题?

  • 相关阅读:
    QT编程,QMainWindow、事件
    《DevOps实践指南》笔记:第3章
    【翻译】Controlling Perceptual Factors in Neural Style Transfer
    〖全域运营实战白宝书 - 高转化文案速成篇③〗- 高打开率标题型文案的10大黄金法则
    Mybatis - XML
    第11章 AOF持久化
    Koordinator 协同 containerd NRI 增强容器 QoS,提升应用性能
    WSO2 API Manager代码问题漏洞(CVE-2022-29464)
    大数据从入门到精通(超详细版)之Hive的DDL操作
    产品运营的场景和运营策略
  • 原文地址:https://ask.csdn.net/questions/8080066