我开始使用Spring boot来玩spring Cloud Stream/App Starters。当我按照入门说明进行操作时,mvn build出现以下错误:
An invalid artifact was detected.
This artifact might be in your project's POM, or it might have been included transitively during the resolution process. Here is the information we do have for this artifact:
我有一个使用SpringBoot2.0.3的Spring应用程序。在Finchley.SR1下,libraries和Spring库。具有以下特性:
spring:
kafka:
ssl:
protocol: SASL_SSL
keystore-location: classpath:kafka.p12 // created from a PEM with private key and certificate
keystore-password: passw0rd
key-store-type: PKCS12
cloud:
我打算为Kafka消费者弹性设置多个绑定。更具体地说,备份侦听器具有与主侦听器期望代理IP相同的目的地和组。备份侦听器的autoStartUp在启动时被关闭,但在发生故障转移时将被打开编程。
但是,微服务在启动时会抛出以下异常:
org.springframework.cloud.stream.binder.BinderException: Exception thrown while starting consumer:
at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindCon
你好,我是测试弹簧云和卡夫卡流,并得到错误。
错误日志:
org.springframework.context.ApplicationContextException: Failed to start bean 'inputBindingLifecycle'; nested exception is java.lang.IllegalStateException: A default binder has been requested, but there are no binders available for 'org.springframework.cloud.
我对卡夫卡和春天的云流很陌生。现在,我有一个问题,开始一个卡夫卡项目发送信息。当第一次运行我的应用程序时,它将显示Null指针异常。
日志
java.lang.NullPointerException: null
at java.base/java.util.HashMap.putMapEntries(HashMap.java:497) ~[na:na]
at java.base/java.util.LinkedHashMap.<init>(LinkedHashMap.java:385) ~[na:na]
at org.springframework.cor
我正在尝试使用for process Kinesis Stream启动一个新的示例项目,但我收到以下错误: Exception in thread "-kinesis-consumer-1" java.lang.NoSuchFieldError: logger
at org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter.access$5400(KinesisMessageDrivenChannelAdapter.java:100)
at or
我试图创建一个简单的程序,从一个卡夫卡主题打印一个Kstream。我不断地得到一个NPE和完全没有想法。
我使用了spring云流绑定卡夫卡流依赖关系,我正在使用最新版本的spring "Finchley.M9“。
我所写的代码是:
@Component
@EnableBinding(KafkaStreamsProcessor.class)
public class EventListener{
@StreamListener("input")
public void listen(KStream<String,String> kstrea
我的代码编译得很好,但是当我尝试运行Jar时,在堆栈跟踪中得到以下错误
java.lang.IllegalStateException: Error processing condition on org.springframework.cloud.stream.config.codec.kryo.KryoCodecAutoConfiguration
Caused by: java.lang.IllegalStateException: Failed to introspect Class [org.springframework.cloud.stream.config.ChannelBind
我正在尝试使用框架构建一个简单的Kafka流应用程序。我可以连接到流来推送原始数据进行处理。但是,当我试图处理按键计算事件的流时,我在运行应用程序时会得到Serde class not found: org.apache.kafka.common.serialization.Serde$StringSerde异常。我签入了包含库的项目,我可以找到Serde类,它没有丢失。我不知道为什么在运行时它没有被加载!
下面是我的源文件。
com.pgp.learn.kafka.analytics.AnalyticsApplication
package com.pgp.learn.kafka.analy
当我使用连接名称前缀属性时,应用程序启动失败,如果我删除前缀属性应用程序启动时没有问题。
spring.cloud.stream.rabbit.binder.connection-name-prefix=myPrefix
***************************
APPLICATION FAILED TO START
***************************
Description:
The dependencies of some of the beans in the application context form a cycle:
binderH
我试图使用spring云流向Kafka发送消息,但是send方法会产生以下错误:
Caused by: java.lang.IllegalArgumentException: Magic v1 does not support record headers
at org.apache.kafka.common.record.MemoryRecordsBuilder.appendWithOffset(MemoryRecordsBuilder.java:403) ~[kafka-clients-1.0.0.jar:na]
...
App.java
package com.example.demos