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

Publish Message Queues - Kafka 4.0 Queues (Shared Groups)

Abierto
  • ¿Algo no está bien?
#308 3 comentarios 2 reacciones 0 asignados Ver en GitHub

Los mantenedores suelen responder en 1 día

Nadie ha tomado este issue todavía.

Evaluación

Dificultad
4/5
Tiempo estimado
3-5 días
Aptitud para principiantes
32/100
Tipo de issue
Nueva funcionalidad
Claridad
Bastante claro
Estado de actividad
Estancado
Stack tecnológico
go, kafka
Área
distributed-systems

Línea de trabajo

Start by reading the existing RabbitMQ and AWS SQS queue integrations to understand how queue sources feed events into publishing. Then compare the proposed event fields and Kafka key, topic, payload, and header mapping with the Kafka queues behavior described in the linked reference. Done means Kafka queues can serve as an event source alongside RabbitMQ and SQS, with the proposed event data mapped to Kafka messages.

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

Descripción

enhancement publish-queue

Is your feature request related to a problem? Please describe.
Would be nice to get next to the existing queues also support for the new Kafka Queue system as a source for events to be published. Allowing reuse of an existing Kafka deployment base.

Describe the solution you'd like
Allow next to RabbitMQ & AWS SQS also Kafka Queues to be a source of events to be published. See https://www.confluent.io/de-de/blog/queues-on-kafka/

Considering the following event structure:

{
 "id": "123", // Optional but recommended. If left empty, ID will be generated by hashing the topic, data and timestamp
  "tenant_id": "12345",
  "destination_id": "12345", // Optional. Used to force delivery to a specific destination
  "topic": "something.created", // Optional. Assumed to match ANY topic if left empty.
  "eligible_for_retry": false, // Optional, default to "false". Control if an event should be retried.
  "time": "2024-06-01 08:23:36.082374Z", // ISO Timestamp of the event
  "metadata": {
    // Arbitrary key-value mapping for event
    "key": "value" // String, number or boolean
  },
  "data": {
    // Freeform JSON data
    "hello": "world"
  }
}

id --> Kafka Message Key
time --> time of the message
topic --> Kafka Topic name
data --> Kafka Message payload (json encoded)

Further data could be added as a Headers

Additional context
Add any other context or screenshots about the feature request here.

Lenguaje dominante
Go
Estrellas
1.1k
Forks
70
Merge medio
1 d 3 h
PR fusionados (30 d)
50

Preparar el entorno

Este proyecto no incluye contenedor de desarrollo, Dockerfile ni guía de contribución, así que la configuración corre por tu cuenta: empieza por su README y consulta nuestra guía para la primera contribución para los pasos generales.

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 hookdeck/outpost

Todos los issues de hookdeck/outpost

Issues similares

Más issues de Go

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.