[rocketmq-client-python] TransactionMQProducer allocates an unused producer during initialization
Los mantenedores suelen responder en 1 día
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 2/5
- Tiempo estimado
- 1-3 horas
- Aptitud para principiantes
- 82/100
- Tipo de issue
- Error
- Claridad
- Bien especificado
- Estado de actividad
- Activo
- Stack tecnológico
- python
- Área
- backend, distributed-systems
Línea de trabajo
Lee rocketmq/client.py, centrándote en TransactionMQProducer.__init__ y en los parámetros posicionales de Producer.__init__. Ejecuta la regresión offline con FFI de registro descrita en el issue, usando los valores de opción proporcionados. Se considera terminado cuando la construcción solo llama a CreateTransactionProducer y aplica cada opción una sola vez a ese handle.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
Component
apache/rocketmq-client-python, rocketmq/client.py, TransactionMQProducer.__init__.
Problem
TransactionMQProducer.__init__ calls the Producer initializer with positional arguments (group_id, timeout, compress_level, max_message_size). In Producer.__init__, the second positional parameter is orderly, followed by timeout, compress_level, and max_message_size. Thus construction first allocates a regular/orderly producer and then replaces _handle with the transaction-producer handle, losing the first native handle. When options are supplied, the base initializer also applies them to the discarded handle with shifted meanings before the transaction producer applies them again.
Expected behavior
Transaction-producer construction should allocate only its transaction-producer handle and apply each supplied option to that handle once.
Evidence
An offline recording-FFI regression test invokes the constructor with timeout=1234, compress_level=3, and max_message_size=2048. Before the fix it observes an unexpected CreateOrderlyProducer call; after the fix it observes only CreateTransactionProducer and the correctly targeted setters. No broker or native RocketMQ library is needed for this reproduction.
Scope
This issue concerns the Python wrapper's constructor/resource handling only. It does not require a broker, production data, credentials, or changes to RocketMQ server behavior.
- Lenguaje dominante
- Java
- Estrellas
- 22.7k
- Forks
- 12k
- Merge medio
- 3 d 18 h
- PR fusionados (30 d)
- 17
Preparar el entorno
- Sin Dockerfile ni archivo de Docker Compose
- Tiene una plantilla de pull request
- Leer la guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/rocketmq
-
[Bug] RemotingHelper.connect swaps the socket send and receive buffer configurationPosiblemente ocupada @amalsaidov la tomó hoy. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
Los mantenedores suelen responder en 1 día
-
CompressionType.of fails under the Turkish localePosiblemente ocupada @sharanggupta la tomó hoy. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 83/100
Los mantenedores suelen responder en 1 día
-
[Bug] notifyMasterOnline aborts the long-polling wake-up with a NullPointerException when an arrival drains a bucket firstPosiblemente ocupada @iloveeyjafjalla la tomó hace 29 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
apache/rocketmq#11441 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
[Enhancement] FilterFactory duplicate-registration and unregister semantics lack testsPosiblemente ocupada @chennaji9 la tomó hace 34 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
apache/rocketmq#11340 · 2 comentarios ·
Los mantenedores suelen responder en 1 día
-
[Enhancement] LogicExpression three-valued truth table and short-circuit behavior lack direct testsPosiblemente ocupada @chennaji9 la tomó hace 34 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
apache/rocketmq#11339 · 2 comentarios ·
Los mantenedores suelen responder en 1 día
Todos los issues de apache/rocketmq
Issues similares
-
area/ai area/backend component/zeebe kind/task
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
spAnser/reacharound#38 ·
-
status: Ready
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
MobilityData/gtfs-validator#2254 ·
Los mantenedores suelen responder en 1 día
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 89/100
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
jenkinsci/mcp-server-plugin#305 ·
Los mantenedores suelen responder en 1 día