Matteo Merli
Matteo Merli
@dependabot rebase
> > We shouldn't add some temporary PRs during the release phase unless they are really important. > > @BewareMyPower This PR contains a very important change. The recommended maximum...
Yes, it does make a lot of sense to make that improvement. The current logic, was to try to keep producer/consumers separated to make it easier to implement, although it's...
Client is based on C++ lib which already supports publishing to partitioned topics transparently. The routing mode can be selected with the `messageRoutingMode` property when creating the producer.
Compaction runs in background on a schedule, based on size and time. Perhaps the data was not compacted yet?
> * Is it feasible that a native Python client be developed, or are there any potential show-stopping limitations (i.e., the C++ client can handle some task that Python isn't...
@hangc0276 @zymap We should probably upgrade it first in BookKeeper because it's used by Python functions state.
If you don't need to use Pulsar functions, you can just instance `pip install 'pulsar-client==3.1.0'`. Or, with Avro support: `pip install 'pulsar-client[avro]==3.1.0'`
I was able to reproduce on 3.1.0 client. ``` * thread #1, queue = 'com.apple.main-thread', stop reason = signal SIGSTOP * frame #0: 0x000000018577ebc8 libsystem_kernel.dylib`__psynch_mutexwait + 8 frame #1: 0x00000001857b90c4...
The above stack trace is different from the first one, although similar in principle. There, we got stuck while closing a socket, for which again the mutex should have had...