clear query| facets| time Search criteria: .   Results from 1 to 10 from 86 (0.0s).
Loading phrases to help you
refine your search...
[expand - 4 more] - MirrorMaker 2 - Kafka - [mail # user]
...Verified.On Sat, Jan 18, 2020 at 12:40 PM Ryanne Dolan  wrote:> I think that's right. If there is no per-topic retention configured, Kafka> will use the cluster default.>> R...
   Author: Vishal Santoshi , 2020-01-19, 12:58
[expand - 1 more] - MM2 startup delay - Kafka - [mail # user]
...And can you share the patch...On Sun, Dec 22, 2019 at 10:34 PM Vishal Santoshi wrote:> We also have a large number of topics 1500 plus and in a cross DC> replication. How do we increas...
   Author: Vishal Santoshi , 2019-12-23, 03:35
MirrorMaker 2 Plugin class loader Error - Kafka - [mail # user]
...+1On Mon, Nov 11, 2019 at 2:07 PM Ryanne Dolan  wrote:> Rajeev, the config errors are unavoidable at present and can be ignored or> silenced. The Plugin error is concerning, and w...
   Author: Vishal Santoshi , 2019-11-12, 15:51
[expand - 2 more] - MirrorMaker 2.0 ( working off origin/2.4 ) - Kafka - [mail # user]
...I can verify that the above did take. ( kicking myself ) . It should be thesame for, these too ?b.producer.batch.size = 1048576b.producer.linger.ms  = 30b.producer.acks = 1etc etc...I a...
   Author: Vishal Santoshi , 2019-11-04, 20:27
[expand - 18 more] - Running a stand alone Mirror Maker 2.0 cluster and Issues - Kafka - [mail # user]
...Yep, I increase the number of tasks and the umber of nodes executing thetasks, the above issues appears. It creates the topics ( so non issuereaching the clusters ) but does not create  ...
   Author: Vishal Santoshi , 2019-10-25, 17:25
[expand - 2 more] - Mirror Maker 2.0 cluster and starting from latest offset and other queries - Flink - [mail # user]
...oh shit.. sorry wrong wrong forum :)On Thu, Oct 17, 2019 at 1:41 PM Piotr Nowojski  wrote:> Hi,>> It sounds like setting up Mirror Maker has very little to do with Flink.> S...
   Author: Vishal Santoshi , 2019-10-17, 18:06
[expand - 2 more] - flink 1.9 - Flink - [mail # user]
...Thanks a lot.On Wed, Oct 9, 2019, 8:55 AM Chesnay Schepler  wrote:> Java 11 support will be part of Flink 1.10 (FLINK-10725). You can take the> current master and compile&run it o...
   Author: Vishal Santoshi , 2019-10-09, 15:14
[FLINK-9349] KafkaConnector Exception  while fetching from multiple kafka topics - Flink - [issue]
..../flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java It seems the List subscribedPartitionStates was being modi...
http://issues.apache.org/jira/browse/FLINK-9349    Author: Vishal Santoshi , 2019-07-11, 07:45
[expand - 8 more] - Job recovers from an old dangling CheckPoint in case of Job Cluster based Flink pipeline - Flink - [mail # user]
...I guess using a session cluster rather then a job cluster will decouple thejob from the container and may be the only option as of today?On Sat, Jun 29, 2019, 9:34 AM Vishal Santoshi wrote:&...
   Author: Vishal Santoshi , 2019-07-03, 12:27
[expand - 2 more] - Why did JM fail on K8s (see original thread below) - Flink - [mail # user]
...even thoughMax. number of execution retries Restart with fixed delay (240000 ms). #20restart attempts.On Sat, Jun 29, 2019 at 10:44 AM Vishal Santoshi wrote:> This is strange, the retry s...
   Author: Vishal Santoshi , 2019-06-29, 14:45