例如,在下面的代码中,我使用Kafka作为源,并通过option方法传递源所需的配置。在这里,我只使用了两个选项- server details and topic configuration。我试图找出的是,对于特定格式的数据源或接收器,有哪些其他选项可用,在本例中为Kafka。在Kafka格式的情况下,我可以在Spark文档的Kafka指南中找到一些选项,但我在哪里可以找到其他可用于Kafka格式的选项。我在Spark的所有文档中搜索了这个信息,但没有找到。spar
Kafka的官方文档提供了步骤,到目前为止,我已经完成了所有步骤,以便从源代码运行Kafka。.Java 1.8 and Scala 2.13.5
Generated IDEA project at file:///Users/aviralsrivastava/dev/kafka/kafka.ipr
我安装了Intellij IDEA,但是我
我试图使用身份验证的SchemaRegistry生成/使用Kafka主题中的JSON消息,它可以映射模式。我指的是官方文档,但是提到的JSON序列化器不起作用。Invalid value io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer for configuration value.serializer: Class io.confluent.kafka.serializers.json.KafkaJsonSchemaS