Skip to content

Commit cb7e38d

Browse files
committed
docs, code tweaks
1 parent aa36388 commit cb7e38d

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

README.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -85,9 +85,9 @@ INFO main o.a.k.c.u.AppInfoParser: Kafka startTimeMs: 1715466159773
8585
(producer) bq-kafka-example > Hi again!
8686
```
8787

88-
You can read these messages from the topic using Kafka provided console consumer, but let's start our own consumer.
89-
Open a new terminal window, change to `bootique-kafka-examples/` directory, and run the same Java app, but with
90-
`--consumer` command:
88+
You can read these messages from the `bq-kafka-example` topic using Kafka standard console consumer, but let's start our
89+
own consumer. Open a new terminal window, change to `bootique-kafka-examples/` directory, and run the same Java app,
90+
but with `--consumer` command:
9191

9292
```
9393
java -jar target/bootique-kafka-examples-3.0.jar --consumer \

src/main/java/io/bootique/examples/kafka/ConsumerCommand.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
import io.bootique.command.CommandOutcome;
55
import io.bootique.command.CommandWithMetadata;
66
import io.bootique.kafka.client.consumer.KafkaConsumerFactory;
7-
import io.bootique.kafka.client.consumer.KafkaPollingTracker;
87
import io.bootique.meta.application.CommandMetadata;
98
import org.apache.kafka.clients.consumer.Consumer;
109
import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -38,7 +37,7 @@ public CommandOutcome run(Cli cli) {
3837
return CommandOutcome.failed(-1, "No '--topic' specified");
3938
}
4039

41-
KafkaPollingTracker poll = consumerProvider.get()
40+
consumerProvider.get()
4241
.charValueConsumer()
4342
.group("my-group")
4443
.autoCommit(true)

0 commit comments

Comments
 (0)