org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java (1 line): - line 144: // TODO pool the threads org.apache.aries.events.api/src/main/java/org/apache/aries/events/api/Message.java (1 line): - line 29: * TODO If we allow wild card consumption then a message also needs a topic