Oleksandr Stetsenko issues

Repositories
Issues
Comments

Results 4 issues of


                                            Oleksandr Stetsenko

Offset not committed after partition returned back to worker after 2 rebalances

## Checklist - [ ] I have included information about relevant versions - [ ] I have verified that the issue persists when using the `master` branch of Faust. Do...

self._committed_offset.update(committable_offsets) if did_commit==False

## Checklist - [x] I have included information about relevant versions - [ ] I have verified that the issue persists when using the `master` branch of Faust. Used 2...

bug

Allow no use topic name as partition part

Add a parameter to disable using a topic name as a partition part

Extend list of basic partitioner: FieldAndTimeBasedPartitioner.java & HeaderAndTimeBasedPartitioner.java

We use KafkaConnect to dump topics to AWS S3. Analyzing data is pretty simple with Athena + AWS Glue (Crawlers) + AWS S3. It looks like a common way for...