Apache Kafka集群节点
我的id不显示，而是只显示[myid:]我尝试更改端口号，但仍然有同样的问题。找到附加的错误消息副本。我尝试更改文件名和端口号，并删除服务器财产中的多余空间，但我无法运行Kafka节点群集。请在此处输入图像描述
apache-kafka
当我尝试在KSQL中使用PARTITION BY时，PARTITION BY使用的字段将在值中丢失
我有一个主题test_partition_key_stream，它的模式如下：value:key:null{"id":1,"age":18,"name":"lisa"}然后我这样做了：CREATESTREAMTEST_STREAM_JSON(idINT,ageINT,nameVARCHAR)WITH(KAFKA_TOPIC='test_partition_key_stream',VALUE_FOR
指定多个“；实现＝“0”；quarkus REST api中@requestbody openapi标记中的标记
我有一个quarkusRESTapi，它接受JSON字符串作为事件，然后将它们传播到KAFKA主题。我现在想将可能的JSON字符串的结构放在openAPI合约中。我已经找到了@requestbody标记，它允许我指定一个结构，但我有多种类型的事件，它们都必须指向同一个Kafka主题。我知道这是一个糟糕的场景，但这是我必须处理的，因为我们有一个外部系统生成事件并将JSON发送到我的REST服务，我必须将JSON传播到本地的KAFKA主题。