#898: enhanced SignalFilterTest unit test by testing with "topic:action" for modified events and "topic:subject" for filtering live messages
(details / githubweb)
Introduce source queue for MqttPublisherActors
(details / githubweb)
NamespacedEntityIds cannot identify a connection
(details / githubweb)
Extract inner class to super class as cohesion is very low
(details / githubweb)
add optional MetricsAlert to SlidingWindowCounter that triggers a given action in case a given condition is met, implement ThrottledMetricsAlert that detect if a metric has reached a given threshold, use the ThrottledMetricsAlert to monitor the consumed inbound counters and record threshold exceedance in the new THROTTLED metrics counter, fix DefaultConnectionThrottling config loading the corrct values from the given config
(details / githubweb)
add throttling detection tolerance to configuration, some javadoc and cleanup
(details / githubweb)
use last timestamp to determine the value of throttled metric for 1min measurement window (allowes more accuracy)
(details / githubweb)
handle modifications to throttling config for kafka sources by adapting the costs per message dependent on the configured limit per interval
(details / githubweb)
update throttling alerts on modification of throttling config
(details / githubweb)
fixed drop behavior of mapping queue in LegacyBaseConsumerActor
(details / githubweb)
use classloader of EntityId to find annotated classes
(details / githubweb)
Revert "use classloader of EntityId to find annotated classes"
(details / githubweb)
provide blog post with overview of new kafka consumer feature
(details / githubweb)
add method to get a list of unrestricted authorization subjects to enforcers and use it in concierge to calculate read-subjects
(details / githubweb)
fixed that in Thing3ValudePredicateVisitor the "isUnknownField" did not categorize "extra" fields being in "unknownFields" starting with the actual fieldExpression to check, e.g. "/attributes" might be enriched, then "/attributes/foo" must be categorized as "unknown" field and be not filtered prior to enrichment
(details / githubweb)
added new ResourcePlaceholder providing "resource:type" and "resource:path"
(details / githubweb)
use more common max-queue-size as config key for outbound mqtt queue size
(details / githubweb)
increase size of ack labels according to size increase of connection IDs
(details / githubweb)
stabilize connection live status for amqp 1.0 connections
(details / githubweb)
- Do not block in preStart method of ConnectionSupervisorActor. Instead use message to signal when initialization (retrieval of config) is done.
(details / githubweb)
Fix status 500 when sorting a field containing non-primitive values.
(details / githubweb)
enable loading additional extra JavaScript libraries which can be used in Ditto's JS based payload mapping
(details / githubweb)
fix toString() of Whoami + debug loggin in AbstractHttpRequestActor
(details / githubweb)
Review: Delay AMQP consumer status retrieval.
(details / githubweb)
simplify construction of sinks in kafka consumer streams
(details / githubweb)
publish connection logs via fluency library to fluentd/fluentbit
(details / githubweb)
align sourceStatus presentation for status "unknown/failure/misconfiguration" with status open for mqtt connection;
(details / githubweb)
add prefab values to testEqualsAndHashcode for ConnectionLoggerRegistryTest and DefaultConnectionMonitorRegistryTest;
(details / githubweb)
Throttle kafka consumer stream also after consuming a record from Kafka (throttling after payload mapping has already been implemented). This early throttling avoids being overloaded with malformed messages and processing them at full speed.
(details / githubweb)
omit request body for GET and DELETE requests made via http push connection, add configuration option and allow override via specific config
(details / githubweb)
modified default success/failure/exception message to include the log type in order to e.g. not have "Message processed" message for each log type
(details / githubweb)
Test OAuth endpoint when testing an HTTP connection.
(details / githubweb)
Fix assertion in HttpPublisherActorTest#testOmitRequestBody.
(details / githubweb)
Reduce defaut fetch.max.wait.ms for kafka consumers to 5 seconds
(details / githubweb)
![[Jenkins]](/ditto/static/6e6c02f8/images/svgs/logo.svg){kind=logo}
