You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
# The interval to wait to reconnect
reconnectinterval: 5000,
# The global connection timeout
connecttimeout: 5000,
nats: {
Servers: ["nats:4222"],
ConnectTimeout: 5000,
MaxReconnects: 120,
ReconnectWait: 5000,
}
connect: [
{
type: "JetStreamToKafka",
brokers: ["kafka:29092"],
durablename: "JetStreamToKafka_durablename",
topic: "test-topic",
subject: "test-subject.*.*.params",
keytype: "subject",
},
],
Publish 1 message to NATS jetstream on subject "test-subject.test.123.params"
We can observe message on Kafka topic with key: "test-subject...params"
Given the capability you are leveraging, describe your expectation?
I expect that messages published to Kafka topic have key equal to NATS message subject.
In the example if I publish to "test-subject.test.123.params" I expect kafka message key to be the same. and not just copy of subject that it is subcribed to (which can be a wildcard)
Given the expectation, what is the defect you are observing?
As the doc says about keytype:
subject - the subject the incoming NATS message was sent on is used as the key
What version were you using?
nats-kafka: 1.4.2
nats-server: v2.9.7
What environment was the server running in?
NATS docker image: nats:2.9.7-alpine3.16
Nats-kafka docker image: natsio/nats-kafka:1.4.2
Is this defect reproducible?
Using configuration of connector:
Publish 1 message to NATS jetstream on subject "test-subject.test.123.params"
We can observe message on Kafka topic with key: "test-subject...params"
Given the capability you are leveraging, describe your expectation?
I expect that messages published to Kafka topic have key equal to NATS message subject.
In the example if I publish to "test-subject.test.123.params" I expect kafka message key to be the same. and not just copy of subject that it is subcribed to (which can be a wildcard)
Given the expectation, what is the defect you are observing?
As the doc says about keytype:
It is a defect on line:
nats-kafka/server/core/connector.go
Line 400 in a2281b5
The text was updated successfully, but these errors were encountered: