Skip to content

Commit f919f41

Browse files
authored
use LookupKey in StreamKeyReader (#216)
1 parent 7b83aef commit f919f41

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

client/src/main/kotlin/io/hstream/impl/StreamKeyReaderKtImpl.kt

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -39,11 +39,10 @@ class StreamKeyReaderKtImpl(
3939

4040
private fun doStart() {
4141
logger.info("streamKeyReader $readerName is starting")
42-
val lookupRequest = LookupResourceRequest.newBuilder()
43-
.setResType(ResourceType.ResStream)
44-
.setResId(streamName)
42+
val lookupRequest = LookupKeyRequest.newBuilder()
43+
.setPartitionKey(key)
4544
.build()
46-
val lookupResp = client.unaryCallBlocked { it.lookupResource(lookupRequest) }
45+
val lookupResp = client.unaryCallBlocked { it.lookupKey(lookupRequest) }
4746
val serverUrl = lookupResp.host + ":" + lookupResp.port
4847
val requestBuilder = ReadStreamByKeyRequest.newBuilder()
4948
.setReaderId(readerName)

client/src/main/proto

Submodule proto updated 1 file

0 commit comments

Comments
 (0)