正在显示
1 个修改的文件
包含
5 行增加
和
2 行删除
| @@ -33,7 +33,10 @@ | @@ -33,7 +33,10 @@ | ||
| 33 | 33 | ||
| 34 | #ifdef SRS_AUTO_KAFKA | 34 | #ifdef SRS_AUTO_KAFKA |
| 35 | 35 | ||
| 36 | -// https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ApiKeys | 36 | +/** |
| 37 | + * the api key used to identify the request type. | ||
| 38 | + * @see https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ApiKeys | ||
| 39 | + */ | ||
| 37 | enum SrsKafkaApiKey | 40 | enum SrsKafkaApiKey |
| 38 | { | 41 | { |
| 39 | SrsKafkaApiKeyProduceRequest = 0, | 42 | SrsKafkaApiKeyProduceRequest = 0, |
| @@ -178,7 +181,7 @@ public: | @@ -178,7 +181,7 @@ public: | ||
| 178 | */ | 181 | */ |
| 179 | virtual int header_size(); | 182 | virtual int header_size(); |
| 180 | /** | 183 | /** |
| 181 | - * the size of message, the left bytes left after the header. | 184 | + * the size of message, the bytes left after the header. |
| 182 | * @remark total_size = 4 + header_size + message_size. | 185 | * @remark total_size = 4 + header_size + message_size. |
| 183 | */ | 186 | */ |
| 184 | virtual int message_size(); | 187 | virtual int message_size(); |
-
请 注册 或 登录 后发表评论