Pierre MORVAN
Pierre MORVAN
Inspired from https://github.com/Shopify/sarama/pull/1527 Fix: * https://github.com/Shopify/sarama/issues/1829 * https://github.com/Shopify/sarama/issues/1760 Changes: * Add BeginTxn/CommitTxn/AbortTxn/AddOffsetsToTxn/AddMessageToTxn to Sync/Async Producer Example usage: (for more complete examples see examples/txn_producer && examples/exactly_once) * Simple transaction producer ```go...
## Spec A module to manage dynamics configurations ## Proposed module ```yaml kafka_configs: # Classic configuration options ... configs: - resource_type: broker resource_name: test options: key: value ```
When i tried to use `DescribeConfigsResponse_v1` i realised that it contain `is_default` field but Kafka protocol changed for this version to replace `is_default` with `config_source`. This fix the response. ---...