python (65.1k questions)

javascript (44.2k questions)

reactjs (22.7k questions)

java (20.8k questions)

c# (17.4k questions)

html (16.3k questions)

r (13.7k questions)

android (12.9k questions)

Questions - consumer

StreamBuilder / ChangeNotifierProvider- setState() or markNeedsBuild() called during build

Streambuilder, ChangeNotifier and Consumer cannot figure out how to use correctly. Flutter I've tried and tried and tried, I've searched a lot but I cannot figure this out: I'm using a Streambuilder t...
test-img

Mirakle

flutter

consumer

stream-builder

flutter-change-notifier

flutter-streambuilder

Votes: 0

Answers: 1

Latest Answer

it is not possible to setState(or anything that trigger rerender) in the builder callback just like you don't setState in React render const A =()=>{ const [state, setState] = useState([]) re...
test-img

Acid Coder

Kafka built on Kubernetes gets stuck while consuming

I installed Kafka(3.1.0) as Stateful on Kubernetes. Then I created a Topic. We send data to this topic by receiving data with HA proxy from outside of Kubernetes. Then we consume this data with an app...
test-img

Çetin Kesepara

kubernetes

apache-kafka

consumer

Votes: 0

Answers: 0

Spring Kafka multiple topic for one class dynamically

I recently wanted to add a new behavior in my project that uses spring-kafka. The idea is really simple : App1 create a new scenario name "SCENARIO_1" and publish this string in the topic &...
test-img

Lucsartes

java

apache-kafka

spring-kafka

consumer

Votes: 0

Answers: 1

Latest Answer

There are several answers here about dynamically creating containers... Trigger one Kafka consumer by using values of another consumer In Spring Kafka Kafka Consumer in spring can I re-assign partitio...
test-img

Gary Russell

get results from kafka for a specific period of time

Here is my code, that uses kafka-python. now = datetime.now() month_ago = now - relativedelta(month=1) topic = 'some_topic_name' consumer = KafkaConsumer(topic, bootstrap_servers=PROD_KAFKA_SERVER, ...
test-img

Анастасия Мелентьева

python

apache-kafka

consumer

kafka-python

Votes: 0

Answers: 2

Latest Answer

Get topic partitions, assigned to your consumer: partitions = consumer.assignment() Get offsets for partitions by datetime: month_ago_timestamp = int(month_ago.timestamp() * 1000) partition_to_timest...
test-img

Trizalio

Posts

Questions

Blogs

Jobs