Marek Czajkowski

Pulsar blocks vertx thread when blockIfQueueFull is true

6

When blockIfQueueFull is set to true for pulsar producer it might happen that when the queue limit is reached producer is blocked and it block the event loop. Sending message...

In reference to the discussion from this issue [https://github.com/smallrye/smallrye-reactive-messaging/issues/2548#issuecomment-2037205262](https://github.com/smallrye/smallrye-reactive-messaging/issues/2548#issuecomment-2037205262) The backpressure mechanism in the SmallRye Pulsar connector does not consider memory limit settings. While Pulsar clients can be configured with...

Event time based compaction

5

Draft with Event time based topic compaction

[improve][pip] PIP-352: Event time based topic compactor

6

PIP: 352 ### Motivation Currently, there are two types of compactors available: `TwoPhaseCompactor` and `StrategicTwoPhaseCompactor`. The latter is specifically utilized for internal load balancing purposes and is not employed for...

Fixes [#23161](https://github.com/apache/pulsar/issues/23161) Main Issue: #xyz ### Motivation java.lang.AssertionError: expected [5] but found [6] at org.testng.Assert.fail(Assert.java:110) at org.testng.Assert.failNotEquals(Assert.java:1577) at org.testng.Assert.assertEqualsImpl(Assert.java:149) at org.testng.Assert.assertEquals(Assert.java:131) at org.testng.Assert.assertEquals(Assert.java:1418) at org.testng.Assert.assertEquals(Assert.java:1382) at org.testng.Assert.assertEquals(Assert.java:1428) at org.apache.pulsar.broker.service.CurrentLedgerRolloverIfFullTest.testCurrentLedgerRolloverIfFull(CurrentLedgerRolloverIfFullTest.java:84) at...

Maven bootstrap resolver - wrong pom resolution during QuarkusMainTest

5

### Describe the bug When running QuarkusMainTest via maven in the project causes "fresh" dependencies downloads. What is more this dependencies are downloaded not considering the actual pom settings. In...

'Targeted' does not support null values

1

NullPointerException is thrown when trying to create Targeted with null value. ```java @Incoming("in") @Outgoing("out1") @Outgoing("out2") public Targeted process(Double price) { return Targeted.of("out1", price) } ``` It is a common case...

For now, the authentication of PulsarConnection requires a secret that only can be accessed in the same namespace of the PulsarConnection cr. It should be configurable, the default namespace is...