我们使用的是sasl_tls机制和bitnami/kafka头盔图。我们使用加密和证书管理器来颁发证书。从“让我们加密生成的证书”中创建一个秘密,并将该秘密传递给舵图中的existingSecrets参数。现在,当我使用KafkaJS库连接到Kafka时,使用ssl: true会抛出一个错误:
KafkaJSConnectionError: Connection error: unable to verify the first certificate
详细步骤/如何生成:
启用了对kafka图表的外部访问,以便在端口9094给我们一个IP。
externalAccess.enab
启动流应用程序(使用卡夫卡流)失败时使用"java.lang.IllegalStateException:这不应该发生,因为headers()应该只在处理记录时调用“
这似乎只有当我启动应用程序时,在主题中已经有数据时才会发生。如果主题是空的,并且我开始将数据推送给它,那么一切都很好。
有人知道为什么会发生这种事吗?
谢谢
This should not happen as headers() should only be called while a record is processed
java.lang.IllegalStateException: This should no
我正在尝试在aws上部署kafka。运行kafka服务器时,我得到以下错误:
kafka.common.KafkaException: Socket server failed to bind to hostname:9092: Cannot assign requested address.
at kafka.network.Acceptor.openServerSocket(SocketServer.scala:309)
at kafka.network.Acceptor.<init>(SocketServer.scala:237)
应用程序A写入用户对象(Json)下面的Kafka主题:
public class UserEvent {
private UUID id;
private Object payload; // contains User fields name etc.
}
应用程序B试图使用下面的User.java(多个绑定程序)使用这个用户对象(User.java驻留在应用程序B项目中):
binders:
azureEventHub:
type: kafka
environment:
spring: