我成功地创建了一个主题,测试主题。当我尝试使用curl命令为主题生成数据时:
curl -v -X POST -H "Content-Type: application/json" -H "Accept: application/json" \
--data '{"records":[{"key":"jsmith","value":"alarm clock"}, \
{"key":"htanaka","value":"batteries"},{"key":"awalther","value":"bookshelves"}]}' \
"http://localhost:8082/topics/test-topic"
字符串
我得到以下响应:
第一个月
我在Docker日志中看到了这个异常:
剩余代理|[2023-07-08 07:40:46,829] ERROR Request Failed with exception(io.confluent.rest.exceptions.DebuggableExceptionMapper)rest-proxy| javax.ws.rs.NotSupportedException:HTTP 415不支持的媒体类型rest-proxy|在org.glassfish.jersey.server.internal.routing.MethodSelectingRouter.getMethodRouter(MethodSelectingRouter.java:421)... POST /topics/test-topic HTTP/1.1”415 62“-”“curl/7.87.0”4(io.confluent.rest-utils.requests)
已尝试更改内容类型:“内容类型:application/vnd.kafka.json.v3+json”,但表现相同。
任何见解赞赏。
2条答案
按热度按时间wn9m85ua1#
请参阅README.md了解REST代理。V3 API的格式和URL与V2不同。Confluent的快速入门页面尚未更新。
下面是一个单一数据值的V3 curl post:
字符串
下面是一个包含多个数据值的V3 curl帖子:
型
yh2wf1be2#
上述来自www.example.com文件的示例README.md没有提供Kafka密钥值。下面是一些键值的例子,这些键值可以用于数据的分区放置。
单值:
字符串
多个值:
型