Search results

support multiple Pulsar subscription types

Status: Open.

#90 In numaproj-contrib/apache-pulsar-java;

· ccm32004 opened on Apr 24, 2026

current getPartition impl causing watermark issues for partitioned topics

Status: Open.

#87 In numaproj-contrib/apache-pulsar-java;

· ccm32004 opened on Apr 21, 2026

raise minimum code coverage threshold

Status: Open.

#82 In numaproj-contrib/apache-pulsar-java;

· ccm32004 opened on Apr 6, 2026

add async ack in consumer

Status: Open.

#57 In numaproj-contrib/apache-pulsar-java;

· ccm32004 opened on Feb 4, 2026

update docs to use quay link

Status: Open.

#48 In numaproj-contrib/apache-pulsar-java;

· jacque1ine opened on Apr 25, 2025

Support JSON, Protobuf for Schema Registry

Status: Open.

#45 In numaproj-contrib/apache-pulsar-java;

· jacque1ine opened on Apr 25, 2025

Load test to provide recommendations on min and max pods depending on message size

Status: Open.

#44 In numaproj-contrib/apache-pulsar-java;

· jacque1ine opened on Apr 25, 2025

Load testing for getPending and getPartitions

Status: Open.

#43 In numaproj-contrib/apache-pulsar-java;

· jacque1ine opened on Apr 25, 2025

Use Pulsar built AVRO serialization on producer/consumer

Status: Open.

#42 In numaproj-contrib/apache-pulsar-java;

· jacque1ine opened on Apr 25, 2025

AVRO Source - Define incoming data

Status: Open.

#40 In numaproj-contrib/apache-pulsar-java;

· jacque1ine opened on Apr 25, 2025

Profile getPending and getPartitions methods in UDSource

Status: Open.

#37 In numaproj-contrib/apache-pulsar-java;

· jacque1ine opened on Apr 16, 2025

Experiment removing the enabled flag

Status: Open.

#35 In numaproj-contrib/apache-pulsar-java;

· KeranYang opened on Apr 7, 2025