我刚接触docker,在Docker容器中运行Kafka代理时遇到了问题。我和kafka开发了spring boot应用程序,生产者和消费者在同一个应用程序中。应用程序在没有docker的情况下成功运行,但当我尝试通过主机上的docker容器运行它时,会出现以下错误:
org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not
我正在使用教程尝试基本的spring引导卡夫卡应用程序。
我的项目层次如下:
SpringBootKafkaApplication.java
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class SpringBootKafkaApplication{
public static void main(String[] ar
我正在使用v2.7.5开发一个简单的Spring,并试图将消息发送到事件中心。有人能指点我吗?
错误:
java.lang.RuntimeException: non-nullable field authBytes was serialized as null
at org.apache.kafka.common.message.SaslAuthenticateResponseData.read(SaslAuthenticateResponseData.java:137) ~[kafka-clients-3.1.2.jar:na]
at org.apache.kafka.co
我可以通过io.restassured.RestAssured确认端点在单元测试中工作。然而,在我启动服务之后,每个端点总是返回一页系统信息,例如 # HELP kafka_producer_node_request_total The total number of requests sent
# TYPE kafka_producer_node_request_total counter
kafka_producer_node_request_total{client_id="kafka-producer-metric-message-out",kafka_version
我试图探索使用Kafka和Spring的Spring集成。我正在学习本教程
我正在使用该文档中提供的依赖项,但我得到了以下异常
Caused by: org.xml.sax.SAXParseException: cvc-complex-type.3.2.2: Attribute 'compression-codec' is not allowed to appear in element 'int-kafka:producer-configuration'.
我认为这是一个jar不匹配的问题,但我无法解决它,我试图改变版本很多,但组合并不适合我。请找到我下面的g
我是新卡夫卡,弹力靴,并试图整合卡夫卡和弹性搜索在我的弹力启动应用程序。
当我尝试运行springboot应用程序时,我会看到下面的错误:
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'kafkaListenerContainerFactory' defined in class path resource [org/springframework/boot/autoconfigure/kafka/KafkaAnnotationDrivenConfi
如果我发送字符串,我的代码运行正常,但是当我尝试使用JSON时,我得到了错误消息。
配置文件:
@Configuration
public class KakfaConfiguration {
@Bean
public ProducerFactory<String, PriceRangeModel> produceConofig() {
Map<String, Object> configs = new HashMap<>();
configs.put(ProducerConfig.BOOTSTRAP_S
当我使用http协议kafka运行时,我对kafka有一个问题,没有任何问题。
但是在将协议从http升级到https之后
升级后,所有服务都返回相同的错误。
2021-10-28 23:16:26.367 WARN 1 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node 1 (/206.189.178.228:9092) could not be established. Broker may not be ava
卡夫卡生产者的Spring引导属性:
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.client-id=bam
#spring.kafka.producer.acks= # Number of acknowledgments the producer requires the leader to have received before considering a request complete.
spring.kafka.producer.batch-size=0
spring.kafka.producer.boots