通过CSV文件，通过KAFKA API将数据从Azure Databricks流到Azure事件中心
我是Azure Databricks和Event Hubs的新手。我一直在努力使用SPARK和KAFKA API将数据从Databrick流传输到事件中心。我想要流的数据在.CSV文件中。流启…
我正在尝试从kafkajs消费kafka消息，但无法阅读该消息，
我正在尝试从Kafkajs食用Kafka消息，但无法阅读该消息，请让我知道这个问题。知道如何解决这个问题吗？ const kafka = new Kafka({ logLevel: logLeve…
Confluent Kafka库是否允许在运行时间创建一个消费者组
我需要使用Kafka IADMinclient或任何其他将Kafka曝光的接口创建消费者组。 我了解，通过将true设置为允许。 就我而言，连接到活动中心。在事件中心，…
FLINK -KAFKA连接器恰好一次错误
我正在使用Flink 1.15.0。 For Kafka integration I wrote KafkaSource: public static KafkaSource kafkaSource(String bootstrapServers, String to…
用EJB配置Kafka消费者？是否可以使用EJB为KAFKA配置MDB？
我想用Apache Kafka消息消费者替换EJB中现有的JMS消息消费者。我无法弄清楚使用EJB配置配置Apache Kafka消费者的选项。…
Spring Kafka握手故障无X.509客户端验证证书，但我的密钥库中有一个
我有一个我不知道的情况。 我在K8S中的Springboot应用程序中运行，并尝试使用公司内的Spring Kafka从Kafka主题中进行消费者，我必须使用SSL身份验证。…
无法在Nestjs进行Kafka事件
我在主和控制器文件中具有以下配置。我有一个外部kafka ，我在 main.ts 中定义了 app.connectMicroservice({ transport: Transport.KAFKA, options: {…
Kafkareplytemplate投掷：支持答复需要Kafkatemplate？
这是。 现在，我得到 java.lang.illegalstateException：需要Kafkatemplate来支持答复。我的设置现在看起来像这样。 @Configuration @EnableKafka pub…
发送到Kafka时如何拆分Spark DataFrame？
我正在使用以下语句将我的数据装置写给Kafka。 dataFrame.write.format("kafka") .options(options).save() 不幸的是，上面的代码是将大量的数据帧写…
弗林布林窗口中的Flink聚合功能自动在两个窗户中拆分，以实现大窗口尺寸
我使用不同的窗口尺寸在某些记录上计算一个简单的均值。使用 1小时和 1周的Windows 没有问题，并且结果计算正确。 var keyed = src .filter(event -> …
试图称呼该方法弹簧kafka
我在将Spring-Kafka与Spring-Boot集成在一起时遇到了一些麻烦。我使用Spring Boot v2.1与Spring-Kafka v2.2（应根据矩阵兼容）。 我已经看到了多个类…
使用Kafka Connect时，如何根据AVRO方案转换所有时间戳字段？
在我们的数据库中，我们有20多个字段，我们需要从长时间转换为时间戳。为什么没有通用解决方案来传输所有这些值？ 我知道我可以定义： "transforms":"…
如何在Golang嘲笑Kafka的依赖性和作家？
我有一个结构， type Server struct { grpcServerPort int grpcServer *grpc.Server writer *kafka.Writer } 该服务器有很多方法，包括 - func NewSer…
Elasticsearch无法到达：[http：// kafka：9200/] [manticore :: socketException]连接拒绝
我正在尝试使用Logstash，Elastic Search，Kafka和Kibana运行Spring应用程序。 [main] Attempted to resurrect connection to dead ES instance, but …
