Comments (4)
sabbyanandan
commented on July 25, 2024
This is already supported.
from spring-cloud-stream-binder-kafka.
dvsridhar
commented on July 25, 2024
Is this available in Brooklyn.RELEASE, we are noticing static portioning is not working as expected.
we are setting the following JVM arguments as part of each microservice boot up ( -Dspring.cloud.stream.instanceIndex=(0..1) -Dspring.cloud.stream.instanceCount=2) and all the messages are distributed dynamically.
Also, according to M1 release notes (https://spring.io/blog/2016/08/26/spring-cloud-stream-brooklyn-m1-is-available) the static partition feature will be available in the final release. Do we know what's that release would be? Because this feature used to work with 0.8 consumer but not with the new version anymore.
from spring-cloud-stream-binder-kafka.
mbogoevici
commented on July 25, 2024
Hi @dvsridhar,
Please use the autoRebalanceEnabled option of the Kafka Binder http://docs.spring.io/spring-cloud-stream/docs/Brooklyn.RELEASE/reference/htmlsingle/#_kafka_consumer_properties.
Please open a new issue if you need further support.
from spring-cloud-stream-binder-kafka.
dvsridhar
commented on July 25, 2024
Awesome that works. Thank you very much for all the help.
from spring-cloud-stream-binder-kafka.
Related Issues (20)
- @EmbeddedKafka not working properly with GlobalKTable and transformer HOT 1
- Live producer threads and dynamic-destination-cache-size property HOT 2
- How to wait for future inside Kafka Stream map()? HOT 2
- DefaultErrorHandler not exists HOT 4
- ClassCastException in pipeline: Kafka Streams Function -> Kafka Function -> Kafka Streams Consumer HOT 5
- NOT_ENOUGH_REPLICAS Errors After Upgrading The Spring Boot And Spring Cloud Version HOT 5
- KafkaBinderMetrics prevent JVM shutdown due to not shutting down scheduler thread pool! HOT 8
- Kafka bindings from previous test class remains active in the next test class HOT 2
- Kafka Streams Serdes having nested generic doesn't work HOT 3
- Support for DLQ in batch mode HOT 1
- spring.cloud.stream.bindings.process-in-0.consumer.concurrency not working in case of UpperCase letter in process name HOT 1
- ListenerContainerWithDlqAndRetryCustomizer template points to localhost:9092 HOT 5
- Looking for a sample with AWS MSK IAM
- [Feature Request] Allow to accept a list of customizers instead of a unique one for KafkaMessageChannelBinder HOT 1
- spring-kafka-test is compile (not test) dependency of spring-cloud-stream-binder-kafka-streams:3.2.3 and 3.2.4
- Batch mode is not working HOT 1
- Unknown Autoconfigured KafkaAvroSerializer and KafkaAvroDeSerializers HOT 2
- Spring Cloud stream binder kafka DLQ Handling for Batching doesn't work HOT 2
- Enable DLQ with destinations as pattern
- Fetch message timestamp
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from spring-cloud-stream-binder-kafka.