How to use a kafka container in kubernetes?

2022-12-12 Thread Mario Ricci
://stackoverflow.com/questions/74776463/kafka-container-on-local-kubernetes-for-integration-tests-crashing-or-not-acce Any help would be much appreciated, *Mario Ricci* Technical Lead Architect | D&E Construction 10368 Westmoor Dr., Westminster, CO

Re: Process to enable log compaction on a cluster

2016-10-12 Thread Mario Ricci
n to the service, so before trying I want to make sure, there > is a > > cleaner process here. > > > > Any help/pointers will be greatly appreciated. > > > > Thanks, > > Sathya > > > > > > > -- Mario Ricci | Software Engineer | Trimble Navigation Limited | VirtualSite Solutions | Office: +1 (303) 635-8604 / x228604

RE: Receiving "The session timeout is not within an acceptable range" but AFAIK it is within range

2016-05-04 Thread Mario Ricci
sumer level settings while creating the consumer, will result in those properties being ignored. Can you confirm where exactly you have set those values? -Jaikiran On Tuesday 03 May 2016 11:25 PM, Mario Ricci wrote: > Hi all, > > This seems like a basic question and I am probably just missing

Receiving "The session timeout is not within an acceptable range" but AFAIK it is within range

2016-05-03 Thread Mario Ricci
Hi all, This seems like a basic question and I am probably just missing something, but when creating my consumer I am getting the error: "The session timeout is not within an acceptable range" My settings seem to be good (group.max and group.min don't violate session.timeout). Here are my set

How to modify confluent consumer config?

2016-04-22 Thread Mario Ricci
I am VERY new to confluent, and need to switch over kafka to use the 0.9 offset storage vs the old zookeeper offset storage. I would like to follow this process http://kafka.apache.org/documentation.html#offsetmigration but do not know where Confluent stores its consumer configuration. How can

Question on Java client consumer.seek()

2016-04-05 Thread Mario Ricci
message to something like: "No current assignment for partition partitionName. If you called seek() you must call poll() first". I can see this being confusing for others, especially if they are designing something that needs to start processing at the end or somewhere in between. Mario Ricci