zalando/nakadi issues and pull requests

#1593 - Prepare for repo archival

Pull Request - State: closed - Opened by a1exsh 7 months ago - 6 comments

#1592 - Mention that event_stream.read|write scopes are not used

Pull Request - State: closed - Opened by ePaul 7 months ago - 1 comment

#1591 - Log debug topic id header for misplaced events

Pull Request - State: closed - Opened by a1exsh 8 months ago - 2 comments

#1590 - temproraly adding topic to kafka record

Pull Request - State: closed - Opened by adyach 8 months ago - 2 comments

#1589 - Extend the validations: retention period mandatory for materialisation opt-in

Pull Request - State: closed - Opened by dgur1n 8 months ago - 1 comment

#1588 - Use opensource docker registry

Pull Request - State: closed - Opened by roskenet 8 months ago - 3 comments

#1587 - Support making DataLake annotations as mandatory upon creation and update of event type

Pull Request - State: closed - Opened by 1u0 8 months ago - 2 comments

#1586 - Expose partition in BatchItemResponse (useful for 207s)

Pull Request - State: closed - Opened by fghibellini 8 months ago - 3 comments

#1585 - Expose partition in BatchItemResponse (useful for 207s)

Pull Request - State: closed - Opened by a1exsh 8 months ago
Labels: minor

#1584 - Expose partition in BatchItemResponse (useful for 207s)

Pull Request - State: closed - Opened by fghibellini 8 months ago
Labels: minor

#1583 - Add configurable timeout for publishing

Pull Request - State: open - Opened by samizzy 8 months ago - 1 comment

#1582 - Update Kafka client version to 3.6.1

Pull Request - State: closed - Opened by a1exsh 10 months ago - 3 comments
Labels: minor

#1581 - Rebalance subscription's sessions on DLQ event type attachment to topology

Pull Request - State: closed - Opened by 1u0 10 months ago - 2 comments
Labels: minor

#1580 - Big cleanup of Hamcrest imports (#1563)

Pull Request - State: closed - Opened by 1u0 10 months ago - 2 comments

#1579 - Workaround: reset subscriptions' running sessions on attaching DLQ pa…

Pull Request - State: closed - Opened by 1u0 10 months ago - 2 comments

#1578 - add maxEventsSendCount

Pull Request - State: closed - Opened by samizzy 10 months ago

#1577 - Fix to not override existing last dead letter offset

Pull Request - State: closed - Opened by a1exsh 10 months ago

#1576 - Revert: Simplify DLQ transitions

Pull Request - State: closed - Opened by fghibellini 10 months ago

#1575 - Fix checkstyle issues

Pull Request - State: closed - Opened by fghibellini 10 months ago

#1574 - Dlq cursor reset

Pull Request - State: closed - Opened by fghibellini 10 months ago

#1573 - [Fix] DLQ mode batches sent

Pull Request - State: closed - Opened by samizzy 10 months ago - 2 comments

#1572 - Reset DLQ state on cursor reset

Pull Request - State: closed - Opened by fghibellini 10 months ago
Labels: minor

#1570 - Auto DLQ: `event_type`, `eid`, `occurred_at` required in metadata

Pull Request - State: closed - Opened by a1exsh 11 months ago - 2 comments

#1569 - More readable DLQ debug information

Pull Request - State: closed - Opened by a1exsh 11 months ago - 1 comment

#1568 - [FEATURE] DLQ redrive and supporting changes

Pull Request - State: closed - Opened by a1exsh 11 months ago - 2 comments
Labels: major

#1567 - Add unprocessable event policy on consumption

Pull Request - State: closed - Opened by a1exsh 11 months ago - 3 comments

#1566 - Feed events one by one until the end of problematic batch

Pull Request - State: closed - Opened by a1exsh 11 months ago - 1 comment

#1565 - Revert master branch to the latest deployed commit

Pull Request - State: closed - Opened by 1u0 11 months ago - 2 comments

#1564 - Workaround: disallow re-partitioning the DLQ redrive event type.

Pull Request - State: closed - Opened by 1u0 12 months ago - 3 comments
Labels: minor

#1563 - Big cleanup of Hamcrest imports

Pull Request - State: closed - Opened by a1exsh 12 months ago - 2 comments

#1562 - Update `org.json` version

Issue - State: closed - Opened by a1exsh 12 months ago - 3 comments

#1561 - Add unprocessable event policy on consumption

Pull Request - State: closed - Opened by a1exsh 12 months ago - 5 comments

#1560 - reduce batch limit per partition

Pull Request - State: closed - Opened by adyach 12 months ago - 2 comments
Labels: bug, bugfix

#1559 - Add support submitting DLQ refeed offsets for subscription api

Pull Request - State: closed - Opened by 1u0 12 months ago - 2 comments

#1558 - Add periodic exclusive job to attach DLQ redrive event type

Pull Request - State: closed - Opened by a1exsh 12 months ago - 2 comments

#1557 - Add periodic exclusive job to attach DLQ redrive event type

Pull Request - State: closed - Opened by a1exsh 12 months ago - 1 comment

#1556 - store failed commit on exit

Pull Request - State: closed - Opened by adyach 12 months ago - 2 comments
Labels: bug, bugfix

#1555 - Move setting of `number_of_events` tag to controller

Pull Request - State: closed - Opened by a1exsh 12 months ago - 2 comments

#1554 - [PoC] Consume from DLQ event type in subscriptions streaming

Pull Request - State: closed - Opened by 1u0 12 months ago - 4 comments

#1553 - Add `number_of_events` tag to `publish_events` spans

Pull Request - State: closed - Opened by a1exsh 12 months ago - 4 comments

#1552 - Nakadi Auto DLQ

Pull Request - State: closed - Opened by adyach about 1 year ago - 2 comments

#1551 - Add feature flag for filtering of misplaced events

Pull Request - State: closed - Opened by a1exsh about 1 year ago

#1550 - Add code for skipping events that do not match intended event type

Pull Request - State: closed - Opened by samizzy about 1 year ago - 4 comments

#1549 - upgrade ZSTD to use latest version

Pull Request - State: closed - Opened by adyach about 1 year ago - 3 comments

#1548 - Update documentation note for allowed/supported event types' `cleanup_policy` updates.

Pull Request - State: closed - Opened by 1u0 about 1 year ago - 3 comments

#1547 - add test case for selective consumption wrt avro

Pull Request - State: closed - Opened by samizzy about 1 year ago - 2 comments

#1546 - simplify logic to verify subscription tag

Pull Request - State: closed - Opened by adyach about 1 year ago

#1545 - Return client error on unknown meta schema

Pull Request - State: closed - Opened by 1u0 about 1 year ago - 3 comments

#1544 - Return client error on unknown meta schema

Pull Request - State: closed - Opened by 1u0 about 1 year ago

#1543 - extend the validations: retention period mandatory for materialisatio…

Pull Request - State: closed - Opened by adrianafirutanasie about 1 year ago - 6 comments

#1542 - Validate `event_owner_selector` path refers to a field in the schema

Pull Request - State: closed - Opened by a1exsh about 1 year ago - 2 comments

#1541 - Enforce alphabetic ISO-4217 currency format validation

Pull Request - State: closed - Opened by 1u0 about 1 year ago - 3 comments

#1540 - Use idempotent producer once again to enable safe retries

Pull Request - State: closed - Opened by a1exsh about 1 year ago - 4 comments

#1539 - [Preview] Handle `OutOfOrderSequenceException` in Kafka producer

Pull Request - State: closed - Opened by a1exsh about 1 year ago - 1 comment

#1538 - Fix retry in `listPartitionNames`

Pull Request - State: closed - Opened by a1exsh about 1 year ago - 3 comments

#1537 - allow fallback to remote on IO error

Pull Request - State: closed - Opened by samizzy about 1 year ago - 8 comments

#1536 - Do not close producers on specific errors

Pull Request - State: closed - Opened by a1exsh about 1 year ago - 2 comments

#1535 - improve logging in event type cache

Pull Request - State: closed - Opened by adyach about 1 year ago - 2 comments

#1534 - evict cache value only if load is successful

Pull Request - State: closed - Opened by adyach about 1 year ago - 2 comments

#1533 - Change logging implementation to Log4j 2.

Pull Request - State: open - Opened by 1u0 over 1 year ago

#1532 - Update README.md test

Pull Request - State: closed - Opened by samizzy over 1 year ago

#1531 - Change logging implementation to Log4j 2.

Pull Request - State: closed - Opened by 1u0 over 1 year ago

#1530 - Relax Kafka producer reset cases

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 5 comments

#1529 - Add logging for ISO-4217 currency format checks

Pull Request - State: closed - Opened by 1u0 over 1 year ago - 4 comments

#1528 - Update zookeeper client

Pull Request - State: closed - Opened by 1u0 over 1 year ago - 3 comments

#1527 - ZDLK-5077 update the validations for datalake annotations

Pull Request - State: closed - Opened by adrianafirutanasie over 1 year ago - 10 comments

#1526 - skipped events

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1525 - Implement optional settings that enable Nakadi security

Pull Request - State: closed - Opened by tor-vs-floki over 1 year ago - 2 comments

#1524 - Revert "multi-timeline consumer pool"

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1523 - POC for Selective consumption for a subscription id

Pull Request - State: closed - Opened by samizzy over 1 year ago - 3 comments

#1522 - Use begin/end offsets API in Kafka consumer

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1521 - Remove reassign() from TopicRepository interface

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1520 - multi-timeline consumer pool

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1519 - Revert "multi-timeline consumer pool for subscription lag"

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1518 - multi-timeline consumer pool for subscription lag

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1517 - separate kafka consumer from nakadi consumer

Pull Request - State: closed - Opened by adyach over 1 year ago - 4 comments

#1516 - reassign topics in multitimeline consumer

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1515 - Fix call to `getConsumer()` w/o client id not being pooled

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1514 - Use Kafka consumer pool always, if it is there

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 3 comments

#1513 - Reinstate Kafka consumer pool and add more metrics

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 3 comments

#1512 - Nakadi in K8S cluster?

Issue - State: open - Opened by cloudcompute over 1 year ago

#1511 - Record Kafka consumer create rate

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1510 - Persist annotations/labels on subscription update

Pull Request - State: closed - Opened by samizzy over 1 year ago - 2 comments

#1509 - Validate datalake annotations

Pull Request - State: closed - Opened by tor-vs-floki over 1 year ago - 2 comments

#1508 - Fix logging around timelag checking

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1507 - rewrite using BlockingQueue

Pull Request - State: closed - Opened by a1exsh over 1 year ago

#1506 - pool kafka consumers for timelag checker, only for test

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1505 - more logs for consumer usage in time lag calculation

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1504 - log consumer closure

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1502 - Add more detail to schema validation errors

Pull Request - State: closed - Opened by samizzy over 1 year ago - 2 comments

#1501 - configure tcp send buffer

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1500 - use event type name

Pull Request - State: closed - Opened by adyach over 1 year ago - 3 comments

#1499 - Count unique `event-type:partition` instances

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 3 comments

#1498 - use producer per topic partition hash

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1497 - choose producer based on the topic

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

#1496 - remove excessive check for the leader

Pull Request - State: closed - Opened by adyach over 1 year ago - 3 comments

#1495 - Update dependencies in `docker-compose`

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 4 comments

#1494 - Upgrade kafka-client to v3.3.2

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1493 - Remove Kafka producer/consumer crutches

Pull Request - State: closed - Opened by a1exsh over 1 year ago - 2 comments

#1492 - Revert "Dedicate a Kafka producer to each of the publishing SLO buckets"

Pull Request - State: closed - Opened by adyach over 1 year ago - 2 comments

GitHub / zalando/nakadi issues and pull requests