Skip to content

Produce on an inexistent partition errors only the second time #21

@martanit

Description

@martanit

To reproduce:

producer←⎕NEW Producer     
producer.configure'bootstrap.servers' 'localhost:9092' 
producer.configure'client.id' 'martina'    

The produce a record on an inexistent partition:

producer.produce_record ⎕NEW #.Record('animals' 'Blackbird' 'key01' 100)   
0 5

the first time, the program returns 0 while, on a second attempt,

producer.produce_record ⎕NEW #.Record('animals' 'Blackbird' 'key01' 100)   
¯190 6

an error is produced (¯190 is RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION).

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions