Skip to content

Exception occurred in configuring ackTimeout attribute, which caused the project to fail to start. #1010

Closed
@Programmer-yyds

Description

@Programmer-yyds

Configure consumer ackTimeout according to the document.
The project cannot be started.
Image

The exception log is as follows:
Caused by: java.lang.IllegalStateException: Error starting listener container [org.springframework.Pulsar.PulsarListenerEndpointContainer#0-0]
at org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer.doStart(DefaultPulsarMessageListenerContainer.java:141)
at org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer.start(AbstractPulsarMessageListenerContainer.java:103)
at org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer.doStart(ConcurrentPulsarMessageListenerContainer.java:100)
at org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer.start(AbstractPulsarMessageListenerContainer.java:103)
at org.springframework.pulsar.config.GenericListenerEndpointRegistry.startIfNecessary(GenericListenerEndpointRegistry.java:234)
at org.springframework.pulsar.config.GenericListenerEndpointRegistry.start(GenericListenerEndpointRegistry.java:186)
at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:323)
... 13 common frames omitted
Caused by: java.lang.RuntimeException: Failed to load config into existing configuration data
at org.apache.pulsar.client.impl.conf.ConfigurationDataUtils.loadData(ConfigurationDataUtils.java:59)
at org.apache.pulsar.client.impl.ConsumerBuilderImpl.loadConf(ConsumerBuilderImpl.java:89)
at org.springframework.pulsar.core.ConsumerBuilderConfigurationUtil.loadConf(ConsumerBuilderConfigurationUtil.java:66)
at org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer$Listener.lambda$new$0(DefaultPulsarMessageListenerContainer.java:336)
at org.springframework.pulsar.core.DefaultPulsarConsumerFactory.lambda$createConsumer$1(DefaultPulsarConsumerFactory.java:119)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
at org.springframework.pulsar.core.DefaultPulsarConsumerFactory.createConsumer(DefaultPulsarConsumerFactory.java:119)
at org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer$Listener.(DefaultPulsarMessageListenerContainer.java:343)
at org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer.doStart(DefaultPulsarMessageListenerContainer.java:131)
... 19 common frames omitted
Caused by: org.apache.pulsar.shade.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: Unrecognized field "ackTimeout" (class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData), not marked as ignorable (37 known properties: "priorityLevel", "autoUpdatePartitions", "acknowledgementsGroupTimeMicros", "receiverQueueSize", "regexSubscriptionMode", "subscriptionName", "retryEnable", "topicsPattern", "autoAckOldestChunkedMessageOnQueueFull", "maxPendingChunkedMessage", "batchIndexAckEnabled", "ackReceiptEnabled", "maxAcknowledgmentGroupSize", "topicNames", "cryptoFailureAction", "subscriptionMode", "consumerName", "expireTimeOfIncompleteChunkedMessageMillis", "maxTotalReceiverQueueSizeAcrossPartitions", "subscriptionProperties", "patternAutoDiscoveryPeriod", "properties", "subscriptionType", "autoUpdatePartitionsIntervalSeconds", "deadLetterPolicy", "ackTimeoutMillis", "maxPendingChuckedMessage", "autoScaledReceiverQueueSizeEnabled", "poolMessages", "replicateSubscriptionState", "readCompacted", "resetIncludeHead", "subscriptionInitialPosition", "negativeAckRedeliveryDelayMicros", "tickDurationMillis", "startPaused", "topicConfigurations"])
at [Source: (String)"{"autoUpdatePartitionsIntervalSeconds":60,"ackTimeout":"60s","tickDurationMillis":1000,"replicateSubscriptionState":false,"negativeAckRedeliveryDelayMicros":60000000,"expireTimeOfIncompleteChunkedMessageMillis":60000,"maxPendingChuckedMessage":10,"topicNames":["topic-1"],"priorityLevel":0,"ackReceiptEnabled":false,"acknowledgementsGroupTimeMicros":100000,"receiverQueueSize":1000,"autoUpdatePartitions":true,"subscriptionMode":"Durable","poolMessages":false,"patternAutoDiscoveryPeriod":60,"subscri"[truncated 549 chars]; line: 1, column: 57] (through reference chain: org.apache.pulsar.client.impl.conf.ConsumerConfigurationData["ackTimeout"])
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:61)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.DeserializationContext.handleUnknownProperty(DeserializationContext.java:1132)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.deser.std.StdDeserializer.handleUnknownProperty(StdDeserializer.java:2202)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.handleUnknownProperty(BeanDeserializerBase.java:1705)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.handleUnknownVanilla(BeanDeserializerBase.java:1683)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.deser.BeanDeserializer.vanillaDeserialize(BeanDeserializer.java:320)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:177)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.deser.DefaultDeserializationContext.readRootValue(DefaultDeserializationContext.java:323)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4730)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3677)
at org.apache.pulsar.shade.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3645)
at org.apache.pulsar.client.impl.conf.ConfigurationDataUtils.loadData(ConfigurationDataUtils.java:57)

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions