KafkaUtil.sendMsg("yjxxt", uname + i % 2 + ":" + i + ":" + System.currentTimeMillis()); 分点

这行代码使用了 KafkaUtil 工具类的 sendMsg 方法，向主题为 "yjxxt" 的 Kafka 集群发送消息。消息内容为一个字符串，格式为 "uname + i % 2 + ":" + i + ":" + System.currentTimeMillis()"，其中 uname 为一个字符串变量，i 为一个整数变量，System.currentTimeMillis() 返回当前时间的毫秒数。每次循环 i 的值都会增加，通过取模操作 i % 2 来生成一个 0 或 1 的值，用于在消息内容中区分不同的发送者。

相关问题

KafkaUtil.sendMsg("yjxxt", "Hello Flink Kakfa" + i + "," + System.currentTimeMillis());

这是发送 Kafka 消息的代码，其中 "yjxxt" 是指 Kafka 的主题，"Hello Flink Kafka" + i + "," + System.currentTimeMillis() 是消息的内容，可以根据实际需求进行修改。你需要先引入 Kafka 的依赖，然后创建一个 Kafka 生产者实例，使用该实例发送消息即可。具体实现可以参考以下代码示例：

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;

public class KafkaUtil {
    private static KafkaProducer<String, String> producer = null;

    static {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", StringSerializer.class.getName());
        props.put("value.serializer", StringSerializer.class.getName());
        producer = new KafkaProducer<>(props);
    }

    public static void sendMsg(String topic, String msg) {
        ProducerRecord<String, String> record = new ProducerRecord<>(topic, msg);
        producer.send(record);
    }
}

需要注意的是，这里使用了 Kafka 的默认配置，如需要进行配置修改可以在 Properties 中指定相应的配置项。

linux内核socket+回调函数

Linux内核中的Socket是一种用于网络通信的抽象接口，它允许应用程序通过网络进行数据传输。在Linux内核中，Socket通信的实现主要依赖于回调函数。

回调函数是一种特殊的函数，它在某个事件发生时被调用。在Socket编程中，回调函数主要用于处理网络事件，例如接收到新的连接、接收到数据等。

在Linux内核中，Socket通信的实现主要涉及以下几个关键概念和回调函数：

1. Socket创建：应用程序通过调用socket()系统调用创建一个Socket对象。在内核中，会调用sock_create()函数创建一个新的Socket对象，并将其与相应的协议族关联起来。

2. Socket绑定：应用程序通过调用bind()系统调用将Socket对象与一个特定的地址和端口进行绑定。在内核中，会调用sock_bind()函数将Socket对象与指定的地址和端口进行关联。

3. Socket监听：应用程序通过调用listen()系统调用将Socket对象设置为监听状态，等待客户端的连接请求。在内核中，会调用sock_listen()函数将Socket对象设置为监听状态，并注册一个回调函数来处理新的连接请求。

4. Socket接收连接：当有新的连接请求到达时，内核会调用之前注册的回调函数来处理该连接请求。在内核中，会调用sock_accept()函数接受新的连接，并调用相应的回调函数进行处理。

5. Socket接收数据：当有数据到达时，内核会调用之前注册的回调函数来处理接收到的数据。在内核中，会调用sock_recvmsg()函数接收数据，并调用相应的回调函数进行处理。

6. Socket发送数据：应用程序通过调用send()或者write()系统调用将数据发送给远程主机。在内核中，会调用sock_sendmsg()函数发送数据，并调用相应的回调函数进行处理。

以上是Linux内核中Socket通信的基本流程和相关回调函数的介绍。