Skip to content

Commit bef8270

Browse files
authored
Create and reuse kafka client where possible (#177)
* Create and reuse kafka client where possible * Code cleanup * fix code style violation
1 parent 3849c40 commit bef8270

File tree

2 files changed

+151
-150
lines changed

2 files changed

+151
-150
lines changed

kafka-webview-ui/src/main/java/org/sourcelab/kafka/webview/ui/manager/kafka/KafkaConsumerFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@ public KafkaConsumer createConsumer(final ClientConfig clientConfig) {
6868
/**
6969
* Create a new KafkaConsumer based on the passed in ClientConfig, and subscribe to the appropriate
7070
* partitions.
71+
* @deprecated To be removed.
7172
*/
7273
public KafkaConsumer createConsumerAndSubscribe(final ClientConfig clientConfig) {
7374
final KafkaConsumer kafkaConsumer = createConsumer(clientConfig);

0 commit comments

Comments
 (0)