Skip to content

Commit 8d2f5ae

Browse files
Specify Neo4j Driver UserAgent for Kafka Connect plugin (#335)
1 parent 1c9287b commit 8d2f5ae

File tree

1 file changed

+2
-0
lines changed
  • kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/sink

1 file changed

+2
-0
lines changed

kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/sink/Neo4jService.kt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import org.neo4j.driver.net.ServerAddress
2222
import org.slf4j.Logger
2323
import org.slf4j.LoggerFactory
2424
import streams.kafka.connect.sink.converters.Neo4jValueConverter
25+
import streams.kafka.connect.utils.PropertiesUtil
2526
import streams.service.StreamsSinkEntity
2627
import streams.service.StreamsSinkService
2728
import streams.service.TopicType
@@ -42,6 +43,7 @@ class Neo4jService(private val config: Neo4jSinkConnectorConfig):
4243

4344
init {
4445
val configBuilder = Config.builder()
46+
configBuilder.withUserAgent("neo4j-kafka-connect-sink/${PropertiesUtil.getVersion()}")
4547

4648
if (!this.config.hasSecuredURI()) {
4749
if (this.config.encryptionEnabled) {

0 commit comments

Comments
 (0)