Uploaded image for project: 'Nuxeo Platform'
  1. Nuxeo Platform
  2. NXP-32353

Kafka topic might not be available after creation when using Kafka 3.5 cluster

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Cannot Reproduce
    • Affects Version/s: None
    • Fix Version/s: 2023.x
    • Component/s: Streams
    • Tags:
    • Upgrade notes:
      Hide

      CI is on 3.6 for a while without problem.

      Show
      CI is on 3.6 for a while without problem.
    • Sprint:
      nxplatform next
    • Story Points:
      3

      Description

      Seen once when starting a single node on an empty Kafka Cluster MSK 3.5.1 with 2 nodes
      kafka.m5.large (with Zookeeper)

      2024-02-27T04:36:37,762 ERROR [main] [org.nuxeo.runtime.model.impl.RegistrationInfoImpl] Component service:org.nuxeo.runtime.stream.service notification of application started failed: Unknown Log name: Name{id='bulk-automationUi', urn='bulk/automationUi
      '}
      java.lang.IllegalArgumentException: Unknown Log name: Name{id='bulk-automationUi', urn='bulk/automationUi'}
              at org.nuxeo.lib.stream.log.internals.AbstractLogManager.lambda$getAppender$3(AbstractLogManager.java:163) ~[nuxeo-stream-2023.7.9.jar:?]
              at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1740) ~[?:?]
              at org.nuxeo.lib.stream.log.internals.AbstractLogManager.getAppender(AbstractLogManager.java:159) ~[nuxeo-stream-2023.7.9.jar:?]
              at org.nuxeo.lib.stream.log.UnifiedLogManager.getAppender(UnifiedLogManager.java:137) ~[nuxeo-stream-2023.7.9.jar:?]
              at org.nuxeo.lib.stream.computation.log.LogStreamManager.lambda$initAppenders$4(LogStreamManager.java:273) ~[nuxeo-stream-2023.7.9.jar:?]
              at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?]
              at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?]
              at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707) ~[?:?]
              at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
              at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
              at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?]
              at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?]
              at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
              at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?]
              at org.nuxeo.lib.stream.computation.log.LogStreamManager.initAppenders(LogStreamManager.java:273) ~[nuxeo-stream-2023.7.9.jar:?]
              at org.nuxeo.lib.stream.computation.log.LogStreamManager.register(LogStreamManager.java:129) ~[nuxeo-stream-2023.7.9.jar:?]
              at org.nuxeo.lib.stream.computation.StreamManager.registerAndCreateProcessor(StreamManager.java:47) ~[nuxeo-stream-2023.7.9.jar:?]
              at org.nuxeo.runtime.stream.StreamServiceImpl.initProcessor(StreamServiceImpl.java:185) ~[nuxeo-runtime-stream-2023.7.9.jar:?]
              at java.base/java.util.ArrayList.forEach(ArrayList.java:1511) ~[?:?]
              at org.nuxeo.runtime.stream.StreamServiceImpl.start(StreamServiceImpl.java:117) ~[nuxeo-runtime-stream-2023.7.9.jar:?]
              at org.nuxeo.runtime.model.impl.RegistrationInfoImpl.start(RegistrationInfoImpl.java:350) [nuxeo-runtime-2023.7.9.jar:?]
              at org.nuxeo.runtime.model.impl.ComponentManagerImpl.startComponent(ComponentManagerImpl.java:742) [nuxeo-runtime-
      

      Note that code path is heavily tested on the CI and in production but not seen.
      This could be related to Kafka 3.5

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                bdelbosc Benoit Delbosc
                Reporter:
                bdelbosc Benoit Delbosc
                Participants:
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: