Hacktoberfest 2026: los issues que los mantenedores marcaron para octubre, abiertos y aptos para principiantes. Explorar issues de Hacktoberfest

[BUG] AMQP Router encounters NPE while getting Exchange

Abierto
  • ¿Algo no está bien?
#1,699 0 comentarios 0 reacciones 0 asignados Ver en GitHub

Los mantenedores suelen responder en 1 día

Nadie ha tomado este issue todavía.

Evaluación

Dificultad
3/5
Tiempo estimado
1-2 días
Aptitud para principiantes
38/100
Tipo de issue
Error
Claridad
Bastante claro
Estado de actividad
Estancado
Stack tecnológico
java
Área
backend, distributed-systems

Línea de trabajo

Start with PersistentQueue.readEntryAsync, especially PersistentQueue.java:90, and trace its callers in AmqpConsumer.java around line 155. Check how PersistentQueue recovery initializes routers and determine the expected behavior when getRouter(exchangeName) is absent; done means the exchange-read path no longer throws this null-pointer failure.

Escrito por el modelo de indexación a partir del texto del issue.

Descripción

type/bug

Describe the bug

Error logs

2025-10-30T14:34:52,611+0000 [pulsar-ph-amqp-123-2] ERROR io.streamnative.pulsar.handlers.amqp.AmqpConsumer - [test-aop.ctag-/10.255.134.236:55732] Failed to read data from exchange topic sample-exchange.
java.util.concurrent.CompletionException: java.lang.NullPointerException: Cannot invoke "io.streamnative.pulsar.handlers.amqp.AmqpMessageRouter.getExchange()" because the return value of "io.streamnative.pulsar.handlers.amqp.impl.PersistentQueue.getRouter(String)" is null
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.thenCompose(Unknown Source) ~[?:?]
	at io.streamnative.pulsar.handlers.amqp.AmqpConsumer.sendMessage(AmqpConsumer.java:155) ~[?:?]
	at io.streamnative.pulsar.handlers.amqp.AmqpConsumer.lambda$sendMessages$1(AmqpConsumer.java:130) ~[?:?]
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173) ~[io.netty-netty-common-4.1.127.Final.jar:4.1.127.Final]
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166) ~[io.netty-netty-common-4.1.127.Final.jar:4.1.127.Final]
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) ~[io.netty-netty-common-4.1.127.Final.jar:4.1.127.Final]
	at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:405) ~[io.netty-netty-transport-classes-epoll-4.1.127.Final.jar:4.1.127.Final]
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998) ~[io.netty-netty-common-4.1.127.Final.jar:4.1.127.Final]
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.netty-netty-common-4.1.127.Final.jar:4.1.127.Final]
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty-netty-common-4.1.127.Final.jar:4.1.127.Final]
	at java.base/java.lang.Thread.run(Unknown Source) [?:?]
Caused by: java.lang.NullPointerException: Cannot invoke "io.streamnative.pulsar.handlers.amqp.AmqpMessageRouter.getExchange()" because the return value of "io.streamnative.pulsar.handlers.amqp.impl.PersistentQueue.getRouter(String)" is null
	at io.streamnative.pulsar.handlers.amqp.impl.PersistentQueue.readEntryAsync(PersistentQueue.java:90) ~[?:?]
	at io.streamnative.pulsar.handlers.amqp.AmqpConsumer.lambda$sendMessage$3(AmqpConsumer.java:155) ~[?:?]
	... 12 more

The exchange router of the PersistentQueue is null; maybe it's related to the PersistentQueue recovery.

public class PersistentQueue extends AbstractAmqpQueue {

    @Override
    public CompletableFuture<Entry> readEntryAsync(String exchangeName, long ledgerId, long entryId) {
        // the method getRouter(exchangeName) return null
        return getRouter(exchangeName).getExchange().readEntryAsync(getName(), ledgerId, entryId);
    }

}
Lenguaje dominante
Java
Estrellas
123
Forks
41
Sin PR fusionados en 30 d

Preparar el entorno

  • Sin Dockerfile ni archivo de Docker Compose
  • Tiene una plantilla de pull request
  • Sin guía de contribución

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Más de streamnative/aop

Todos los issues de streamnative/aop

Issues similares

Más issues de Java

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.