Issues

• refactor: Unify AvroWorker/ByteArrayWorker and AvroSourcer/ByteArraySourcer via a deserializer interface

  numaproj-contrib/kafka-java#38 · Filter by author santho7h opened on Mar 27, 2026
  

• Using auto.offset.reset: earliest causing issues with consumer

  numaproj-contrib/kafka-java#34 · Filter by author cmvs-gh opened on Jan 24, 2026
  3

• Upgrade to Kafka 4.0

  numaproj-contrib/kafka-java#22 · Filter by author KeranYang opened on May 30, 2025

• support non-JSON output type for Avro consumer

  numaproj-contrib/kafka-java#19 · Filter by author KeranYang opened on Jan 14, 2025

• support non-JSON input type for Arvo producer

  numaproj-contrib/kafka-java#18 · Filter by author KeranYang opened on Jan 13, 2025

• support OAuth 2.0

  numaproj-contrib/kafka-java#17 · Filter by author KeranYang opened on Jan 7, 2025

• support plain schema string specified by user

  numaproj-contrib/kafka-java#16 · Filter by author KeranYang opened on Jan 7, 2025

• protobuf support for source and sink

  numaproj-contrib/kafka-java#15 · Filter by author KeranYang opened on Jan 7, 2025

• emit meaningful metrics

  numaproj-contrib/kafka-java#13 · Filter by author KeranYang opened on Dec 19, 2024
  

• multi-topic support

  numaproj-contrib/kafka-java#7 · Filter by author KeranYang opened on Dec 18, 2024
  

• load testing

  numaproj-contrib/kafka-java#6 · Filter by author KeranYang opened on Dec 18, 2024

• propagate headers

  numaproj-contrib/kafka-java#3 · Filter by author KeranYang opened on Dec 12, 2024
  1