Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

kafka: produce messages with id #10

Open
fooinha opened this issue Apr 4, 2017 · 2 comments
Open

kafka: produce messages with id #10

fooinha opened this issue Apr 4, 2017 · 2 comments

Comments

@fooinha
Copy link
Owner

fooinha commented Apr 4, 2017

Allow to produce kafka messages with id.

Many options here:

@fooinha fooinha changed the title kafka produce messages with id kafka: produce messages with id Apr 4, 2017
@driverpt
Copy link

driverpt commented Apr 4, 2017

You set Key in Key-Value Kafka Message

fooinha added a commit that referenced this issue Apr 5, 2017
```

2017/04/04 22:07:09 [debug] 1462#0: *1 http_log_json: kafka
msg-id:[00fec89b2a2ff15b11573f231cc135dc]

msg:[{"_ts":"1491343629.532","req":{"body":"","headers":{"Host":"localhost","User-Agent":"curl/7.52.1","Accept":"*/*"}},"resp":{"headers":{"Last-Modified":"Fri,
31 Mar 2017 16:52:11
GMT","ETag":"\"58de893b-264\"","X-Foo":"bar","Accept-Ranges":"bytes"}}}
]

```
@fooinha
Copy link
Owner Author

fooinha commented Apr 5, 2017

We can test this with test/0.0.5

fooinha added a commit that referenced this issue Apr 5, 2017
```

2017/04/04 22:07:09 [debug] 1462#0: *1 http_log_json: kafka
msg-id:[00fec89b2a2ff15b11573f231cc135dc]

msg:[{"_ts":"1491343629.532","req":{"body":"","headers":{"Host":"localhost","User-Agent":"curl/7.52.1","Accept":"*/*"}},"resp":{"headers":{"Last-Modified":"Fri,
31 Mar 2017 16:52:11
GMT","ETag":"\"58de893b-264\"","X-Foo":"bar","Accept-Ranges":"bytes"}}}
]

```
fooinha added a commit that referenced this issue Apr 9, 2017
```

2017/04/04 22:07:09 [debug] 1462#0: *1 http_log_json: kafka
msg-id:[00fec89b2a2ff15b11573f231cc135dc]

msg:[{"_ts":"1491343629.532","req":{"body":"","headers":{"Host":"localhost","User-Agent":"curl/7.52.1","Accept":"*/*"}},"resp":{"headers":{"Last-Modified":"Fri,
31 Mar 2017 16:52:11
GMT","ETag":"\"58de893b-264\"","X-Foo":"bar","Accept-Ranges":"bytes"}}}
]

```
fooinha added a commit that referenced this issue Apr 9, 2017
* ngx-http-log-json: #10 - kafka msg-id

```

2017/04/04 22:07:09 [debug] 1462#0: *1 http_log_json: kafka
msg-id:[00fec89b2a2ff15b11573f231cc135dc]

msg:[{"_ts":"1491343629.532","req":{"body":"","headers":{"Host":"localhost","User-Agent":"curl/7.52.1","Accept":"*/*"}},"resp":{"headers":{"Last-Modified":"Fri,
31 Mar 2017 16:52:11
GMT","ETag":"\"58de893b-264\"","X-Foo":"bar","Accept-Ranges":"bytes"}}}
]

```

* ngx-json-log: json log for stream
fooinha added a commit that referenced this issue Apr 11, 2017
* ngx-http-log-json: #10 - kafka msg-id

```

2017/04/04 22:07:09 [debug] 1462#0: *1 http_log_json: kafka
msg-id:[00fec89b2a2ff15b11573f231cc135dc]

msg:[{"_ts":"1491343629.532","req":{"body":"","headers":{"Host":"localhost","User-Agent":"curl/7.52.1","Accept":"*/*"}},"resp":{"headers":{"Last-Modified":"Fri,
31 Mar 2017 16:52:11
GMT","ETag":"\"58de893b-264\"","X-Foo":"bar","Accept-Ranges":"bytes"}}}
]

```

* ngx-json-log: json log for stream
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants