Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

Add Integration test to validate unused topics are unloading #163

Open
aahmed-se opened this issue Jun 27, 2020 · 0 comments
Open

Add Integration test to validate unused topics are unloading #163

aahmed-se opened this issue Jun 27, 2020 · 0 comments
Labels
type/feature Indicates new functionality workflow::backlog

Comments

@aahmed-se
Copy link

Pulsar natively supports topic unloading, kafka currently does and it's requested feature, this protocol handler should be able to offer this capability to kafka.

https://issues.apache.org/jira/browse/KAFKA-560

Write a integration test to validate this and add supporting documentation for this use case.
@aahmed-se aahmed-se added the type/feature Indicates new functionality label Jun 27, 2020
BewareMyPower pushed a commit that referenced this issue Oct 15, 2021
@eolivelli
TransactionCoordinator: prevent thread leaks during broker shutdown (#…
1f2d022 
…813)

I noticed this thread leak during the executions of the tests

```
"Thread-3" #163 prio=5 os_prio=0 tid=0x00007f0c34011800 nid=0x603a sleeping[0x00007f0c0dea4000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
        at java.lang.Thread.sleep(Native Method)
        at io.streamnative.pulsar.handlers.kop.coordinator.transaction.TransactionMarkerChannelManager.lambda$new$0(TransactionMarkerChannelManager.java:148)
        at io.streamnative.pulsar.handlers.kop.coordinator.transaction.TransactionMarkerChannelManager$$Lambda$624/1475886210.run(Unknown Source)
        at java.lang.Thread.run(Thread.java:748)
```
this patch fixes the problem

Co-authored-by: Enrico Olivelli <[email protected]>
BewareMyPower pushed a commit that referenced this issue Oct 20, 2021
@eolivelli @BewareMyPower
TransactionCoordinator: prevent thread leaks during broker shutdown (#…
43d1180 
…813)

I noticed this thread leak during the executions of the tests

```
"Thread-3" #163 prio=5 os_prio=0 tid=0x00007f0c34011800 nid=0x603a sleeping[0x00007f0c0dea4000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
        at java.lang.Thread.sleep(Native Method)
        at io.streamnative.pulsar.handlers.kop.coordinator.transaction.TransactionMarkerChannelManager.lambda$new$0(TransactionMarkerChannelManager.java:148)
        at io.streamnative.pulsar.handlers.kop.coordinator.transaction.TransactionMarkerChannelManager$$Lambda$624/1475886210.run(Unknown Source)
        at java.lang.Thread.run(Thread.java:748)
```
this patch fixes the problem

Co-authored-by: Enrico Olivelli <[email protected]>
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
type/feature Indicates new functionality workflow::backlog
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@sijie @aahmed-se