Kafka自学笔记(一)：关于Kafka的配置问题

type

status

date

slug

summary

🤔 你有认真解读过Kafka的配置吗？

没有的话直接去看Kafka官方文档吧，上面配置全面的不能再全面了，点击此处直达所有技术官方文档地址

一、关于消费者配置的注意事项

下面的这三个参数是必须要配置的

bootstrap.servers

key.serializer

value.serializer

你可以参考我实战案例里面的配置，如下代码：

对于Key.serializer与Value.serializer这里有个有意思的细节

Kafka-Server生产者如果推送的是JSON字符串，那么在消费端，使用StringSerializer或者JsonSerializer都可以接收到传递过来的JSON字符串数据。两者有什么区别呢？下面以代码为例

如果您选择使用 StringSerializer，则需要将 JSON 字符串转换为字符串类型，然后再传递给序列化程序进行序列化。

如果您选择使用 JsonSerializer，则无需将 JSON 字符串转换为字符串类型，序列化程序会自动将其转换为 JSON 格式。

请注意，在使用 JsonSerializer 时，您需要提供一个有效的 JSON 对象作为输入。否则，序列化程序可能会引发异常。在使用 JsonSerializer 进行序列化操作时，你需要传入一个有效的 JSON 对象作为参数，否则会抛出异常。JSON对象是一种表示数据的格式，它由键/值对组成，并使用大括号进行包裹。如果你传入一个空的 JSON 对象，那么 JsonSerializer 就无法识别它，因为它没有任何键/值对。这就会导致序列化程序无法将对象转换成 JSON 字符串，从而引发异常。

什么意思呢？在使用 JsonSerializer 时，您需要提供一个有效的 JSON 对象作为输入。否则，序列化程序可能会引发异常。意思就是说，我需要提供一个目标JavaBean序列化之后的JSON对象，哪怕对象属性都是空的都没关系，因为只要是对应JavaBean的JSON对象就可以了，因为后续接受到JSON数据之后，会将JSON数据反序列化成该JavaBean，属性会自动填装回去，通过JsonSerializer进行序列化转换成对应的JSON对象。在这个过程中，即便JavaBean对象的属性为空，也会被转换为对应的JSON对象，并且在反序列化过程中，属性值会自动填充回JavaBean对象中。反之，在将JSON数据反序列化成JavaBean对象时，如果JSON数据缺少某些属性，那么这些属性的值将会保持默认值或者null值，这取决于JavaBean对象的定义。因此，在进行序列化和反序列化操作时，都需要保证JavaBean对象和JSON数据的属性名以及属性类型相匹配，否则可能会导致异常。

所以说，看文档还是很重要的，很多东西，你是从视频中获取不到的，你从视频中能获取到的信息是别人自己掌握的信息，而可能跟你出现信息差，这个时候，果断看官方文档是最正确的选择。少看视频，多看文档~

💡

有关Kafka配置上的其他有趣的问题，欢迎您在底部评论区留言，一起交流~