Yunze Xu
> If we want a topic to support pulsar consumption I'm working on supporting Pulsar consumption for messages whose entry format is Kafka recently. After testing the demo in my...
Yeah, you can see the first optional task in https://github.com/streamnative/kop/issues/581. Since we tracked the task in StreamNative's private repo, this issue was not updated recently.
Overall LGTM but a question. How does the proxy look up the current coordinator?
@sijie Could you also take a look?
@eolivelli @sijie IMO, if the proxy module was not instructive to the `kafka-impl` module, we can accept this proposal and let community users compare it with the existing solutions.
What's your `entryFormat` config? If you configured `entryFormat=kafka`, you need to configure a `KafkaPayloadProcessor` to handle Kafka format messages at the Pulsar consumer side. See https://github.com/streamnative/kop/blob/master/docs/configuration.md#choose-the-proper-entryformat.
No, you only need the `KafkaPayloadProcessor`.
Here's an example. Total time: 38:20 min. | Tests count | time | Test class | | - | - | :- | | 4 | 41.572 s | compatibility.saslplain.SaslPlainEndToEndPulsarTest...
The following application shows the difference between Netty threads and other threads. ```java class ThreadLocalAccessor { @Getter private final Map map = new ConcurrentHashMap(); private final FastThreadLocal local = new...
How to check if the thread managed by Netty? Even And it doesn't solve the problem. Because we need to collect the `LocalData` into the map and remove it when...