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

Confluent kafka binding #988

Merged
merged 1 commit into from
Mar 29, 2024
Merged

Commits on Mar 26, 2024

  1. confluent kafka binding

    Signed-off-by: myan <[email protected]>
    
    add message implementation
    
    Signed-off-by: myan <[email protected]>
    
    add ut test
    
    Signed-off-by: myan <[email protected]>
    
    add integration test
    
    Signed-off-by: myan <[email protected]>
    
    add integration test and samples
    
    Signed-off-by: Meng Yan <[email protected]>
    
    offset
    
    Signed-off-by: Meng Yan <[email protected]>
    
    remove the ctx
    
    Signed-off-by: myan <[email protected]>
    
     review
    
    Signed-off-by: Meng Yan <[email protected]>
    
    remove
    
    Signed-off-by: Meng Yan <[email protected]>
    
    init consumer and producer on 1 client
    
    Signed-off-by: myan <[email protected]>
    
    reply the reviews
    
    Signed-off-by: myan <[email protected]>
    
    fix the ci
    
    Signed-off-by: myan <[email protected]>
    
    ci fix
    
    Signed-off-by: Meng Yan <[email protected]>
    
    add confluent test in github action
    
    Signed-off-by: Meng Yan <[email protected]>
    
    add the mis-used test case
    
    Signed-off-by: Meng Yan <[email protected]>
    
    remove the invalidated bootstrapserver
    
    Signed-off-by: Meng Yan <[email protected]>
    
    log kafka error message
    
    Signed-off-by: myan <[email protected]>
    
    review
    
    Signed-off-by: myan <[email protected]>
    
    Update protocol/kafka_confluent/v2/option.go
    
    Co-authored-by: Michael Gasch <[email protected]>
    Signed-off-by: myan <[email protected]>
    
    add the auto recover option
    
    Signed-off-by: myan <[email protected]>
    
    kafka error handler
    
    Signed-off-by: myan <[email protected]>
    
    remove the delievery chan
    
    Signed-off-by: myan <[email protected]>
    
    Update protocol/kafka_confluent/v2/protocol.go
    
    Co-authored-by: Michael Gasch <[email protected]>
    
    Update protocol/kafka_confluent/v2/protocol.go
    
    Co-authored-by: Michael Gasch <[email protected]>
    
    Update protocol/kafka_confluent/v2/option.go
    
    Co-authored-by: Michael Gasch <[email protected]>
    
    Update protocol/kafka_confluent/v2/protocol.go
    
    Co-authored-by: Michael Gasch <[email protected]>
    
    reply review
    
    Signed-off-by: myan <[email protected]>
    
    modify the git action
    
    Signed-off-by: Meng Yan <[email protected]>
    
    reply review
    
    Signed-off-by: Meng Yan <[email protected]>
    
    reply review
    
    Signed-off-by: Meng Yan <[email protected]>
    
    handle race condition between sender and closer
    
    Signed-off-by: Meng Yan <[email protected]>
    
    reply review
    
    Signed-off-by: Meng Yan <[email protected]>
    
    reply review1
    
    Signed-off-by: Meng Yan <[email protected]>
    
    add defer close
    
    Signed-off-by: Meng Yan <[email protected]>
    
    add comment
    
    Signed-off-by: Meng Yan <[email protected]>
    yanmxa committed Mar 26, 2024
    Configuration menu
    Copy the full SHA
    5cd87ea View commit details
    Browse the repository at this point in the history