Description
Configure consumer ackTimeout according to the document.
The project cannot be started.
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)