Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: dpkp/kafka-python
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: master
Choose a base ref
...
head repository: reciprocity/kafka-python
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: master
Choose a head ref
Checking mergeability… Don’t worry, you can still create the pull request.
  • 17 commits
  • 7 files changed
  • 3 contributors

Commits on Aug 18, 2021

  1. Support AWS_MSK_IAM authentication 

    Adds an AWS_MSK_IAM authentication mechanism which is described here:
* https://github.com/aws/aws-msk-iam-auth#uriencode

To use the mechanism pass the following keyword arguments when
initializing a class:

```
security_protocol='SASL_SSL',
sasl_mechanism='AWS_MSK_IAM',
bootstrap_servers=[
    'b-1.cluster.x.y.kafka.region.amazonaws.com:9088',
    ...
],
```

The credentials and region will be pulled using `botocore.session.Session`.
Using the mechanism requires the `botocore` library which can be
installed with:

```sh
pip install botocore
```

**TODO:**

- [ ] Documentation
- [ ] Tests
- [ ] Refresh mechanism for temporary credentials?
    @mattoberle
    mattoberle committed Aug 18, 2021
    Configuration menu
    Copy the full SHA
    cb18e67 View commit details
    Browse the repository at this point in the history

  2. Use six to import urllib (python2 compatability)

    @mattoberle
    mattoberle committed Aug 18, 2021
    Configuration menu
    Copy the full SHA
    ed99ae5 View commit details
    Browse the repository at this point in the history

  3. Tests AWS_MSK_IAM signature and payload generation 

    The two tests in `test/test_msk.py` should ensure that the changes to
`kafka/msk.py` do not break the authentication payload.

The authentication payload was validated using a real AWS Kafka cluster
before adding tests with the hard-coded signatures.
    @mattoberle
    mattoberle committed Aug 18, 2021
    Configuration menu
    Copy the full SHA
    7ff3237 View commit details
    Browse the repository at this point in the history

Commits on Jan 5, 2022

  1. Merge pull request #1 from mattoberle/feature/2232-AWS_MSK_IAM

    @lgasperin
    lgasperin authored Jan 5, 2022
    Configuration menu
    Copy the full SHA
    e4e6e91 View commit details
    Browse the repository at this point in the history

  2. Move session declaration on msk_iam to outside

    @lgasperin
    lgasperin committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    fa508f0 View commit details
    Browse the repository at this point in the history

  3. Merge pull request #2 from reciprocity/move-session-declaration-to-ou… 

    …tsidee
    @lgasperin
    lgasperin authored Jan 5, 2022
    Configuration menu
    Copy the full SHA
    74a4a7f View commit details
    Browse the repository at this point in the history

  4. Add new iam config to producer

    @lgasperin
    lgasperin committed Jan 5, 2022
    Configuration menu
    Copy the full SHA
    5d65933 View commit details
    Browse the repository at this point in the history

  5. Merge pull request #3 from reciprocity/add-new-config-to-producer

    @lgasperin
    lgasperin authored Jan 5, 2022
    Configuration menu
    Copy the full SHA
    a086a25 View commit details
    Browse the repository at this point in the history

Commits on Jan 6, 2022

  1. Add new config to Consumer and client

    @lgasperin
    lgasperin committed Jan 6, 2022
    Configuration menu
    Copy the full SHA
    c40812b View commit details
    Browse the repository at this point in the history

  2. Fix position

    @lgasperin
    lgasperin committed Jan 6, 2022
    Configuration menu
    Copy the full SHA
    62014ac View commit details
    Browse the repository at this point in the history

  3. Add region_name

    @lgasperin
    lgasperin committed Jan 6, 2022
    Configuration menu
    Copy the full SHA
    8ab5646 View commit details
    Browse the repository at this point in the history

Commits on Jan 7, 2022

  1. Merge pull request #4 from reciprocity/fix-new-config

    @lgasperin
    lgasperin authored Jan 7, 2022
    Configuration menu
    Copy the full SHA
    227089c View commit details
    Browse the repository at this point in the history

Commits on Jan 14, 2022

  1. Build AWS Session in BrokerConnection

    @ebuttiero
    ebuttiero committed Jan 14, 2022
    Configuration menu
    Copy the full SHA
    def4349 View commit details
    Browse the repository at this point in the history

  2. Move Session creation to private method

    @ebuttiero
    ebuttiero committed Jan 14, 2022
    Configuration menu
    Copy the full SHA
    9f713db View commit details
    Browse the repository at this point in the history

Commits on Jan 17, 2022

  1. Merge pull request #5 from reciprocity/svc_672_build_session 

    [SVC-672] Build AWS Session in BrokerConnection
    @ebuttiero
    ebuttiero authored Jan 17, 2022
    Configuration menu
    Copy the full SHA
    c0a3c5e View commit details
    Browse the repository at this point in the history

Commits on Jan 20, 2022

  1. Create a boto session with explicit region_name

    @ebuttiero
    ebuttiero committed Jan 20, 2022
    Configuration menu
    Copy the full SHA
    e7cd7f2 View commit details
    Browse the repository at this point in the history

Commits on Jan 21, 2022

  1. Merge pull request #6 from reciprocity/quick_fix_aws_region_name

    @lgasperin
    lgasperin authored Jan 21, 2022
    Configuration menu
    Copy the full SHA
    842bb0f View commit details
    Browse the repository at this point in the history
Loading