当前位置: 首页 > 知识库问答 >
问题:

为什么syslogudp的Flume中会丢失数据包?

贺刚毅
2023-03-14

使用Flume源syslogudp,我看到大约25%的数据丢失。

这是我的配置

a1.sources = r1

a1.sinks=k1

a1 .通道= c1

a1.sources.r1.type = syslogudp

a1.sources.r1.bind = 172.24.1.78

a1.sources.r1.port = 65535

a1.sinks.k1.type=文件滚动

水槽。水槽。目录=/var/log/tmp

a1.sinks.k1.sink.roll间隔=0

a1 . sinks . k1 . sink . batch size = 20000

a1.channels.c1.type=记忆

a1.channels.c1.capacity=20000

a1.channels.c1.transactionCapacity=20000

a1.sources.r1.channel = c1

a1.sinks.k1.channel = c1

我对RHEL内核参数进行了更改,以解决问题,但没有影响。

sysctl-w net . core . rmem _ max = 33554432

sysctl-w net . IP v4 . UDP _ mem = ' 262144 327680 393216 '

sysctl -w net.core.netdev_max_backlog=2000

有什么建议吗?

共有1个答案

魏勇军
2023-03-14

也许问题出在UDP本身?维基百科 说:

它(UDP)没有握手对话,因此暴露了底层网络协议对用户程序的任何不可靠性。由于这通常是不可靠介质上的IP,因此无法保证交付、订购或重复保护。

 类似资料:
  • 我有五门课: 、、、、。 是文本的持有者。 是空的抽象类。 扩展并存储一个String和一个ArrayList的。 是抽象类并存储

  • 我编写了一个非常简单的Flink流媒体作业,它使用从Kafka获取数据。 这工作得很好,每当我在Kafka上将某些内容放入主题时,它都会被我的Flink作业接收并处理。现在我试图看看如果我的Flink作业由于某种原因不在线会发生什么。所以我关闭了flink作业并继续向Kafka发送消息。然后我再次开始我的Flink作业,并期望它会处理同时发送的消息。 然而,我得到了以下信息: 因此,它基本上忽略了

  • 问题内容: 我有一个与该线程中的问题相似的问题,即使不完全相同: 仅在GoogleChrome和URL重写中随机丢失会话变量 但是该线程中的所有解决方案都不适合我。我的PHP / MySQL应用程序中只有Google Chrome出现了奇怪的行为。如果我在Firefox上尝试过,它可以工作,但Chrome不能。 我导航到购物车中的某个位置,并在代码中的多个位置存储会话数据。不用担心我开始会议或与此

  • 问题是,我想在我的聊天应用程序中使用Firebase云消息。在我的android studio中实现firebase文档,我需要创建一个扩展FirebaseInstancedService的类。然而,这项服务似乎缺失了。

  • 使用window.open打开同源新tab,新页面localstorage中token丢失。