Hello Praneeth,
that looks correct then. In that case, maybe somebody else can chime in.
Are you aware of this post on SO:
https://stackoverflow.com/questions/45047876/apache-kafka-exactly-once-implementation-not-sending-messages
Frank
On Sat, Apr 9, 2022 at 7:42 PM Praneeth Ramesh
wrote:
>
Hi Frank
Thanks for the response.
I see that the min.isr value is 2 and replication factor is 4 in my case.
Do you see any issues with these values..?
Thank you in advance
On Fri, Apr 8, 2022 at 11:28 PM Frank Dekervel wrote:
> Hello,
>
> Check if your topic replication factor is not below mi
Hello,
Check if your topic replication factor is not below min.isr setting of
Kafka. I had the same problem and that was it for me.
Frank
Op za 9 apr. 2022 04:01 schreef Praneeth Ramesh :
> Hi All
>
> I have a job which reads from kafka and applies some transactions and
> writes the data back t
I have inspected mvn dependency:tree in the meantime, the maven build
fortunately looks healthy fortunately, it seems my IntelliJ is very keen on
the freshly acquired dependencies it has gathered recently for scala 2.11.
On Thu, Mar 3, 2016 at 1:04 PM, Márton Balassi
wrote:
> Hey guys,
>
> I hav
Hey guys,
I have run into the same issue when developing against the master. Now
after Max's commit supposedly fixing the issue reimporting the project
gives me all the dependencies for 2.10, except for scala-compiler and
scala-reflect, which come in version 2.11. It seems very weird.
Do you have
This problem is kind of the other way around, as our 2.10 build has 2.11
dependencies pulled in by kafka. But let's see what happens. :)
Gyula
Till Rohrmann ezt írta (időpont: 2016. márc. 3., Cs,
9:46):
> Hi Gyula,
>
> we discovered yesterday that our build process for Scala 2.11 is broken
> fo
Hi Gyula,
we discovered yesterday that our build process for Scala 2.11 is broken for
the Kafka connector. The reason is that a property value is not properly
resolved and thus pulls in the 2.10 Kafka dependencies. Max already opened
a PR to fix this problem. I hope this will also solve your probl
Hey,
Do we have any idea why this is happening in the snapshot repo? We have run
into the same issue again...
Cheers,
Gyula
Gyula Fóra ezt írta (időpont: 2016. febr. 26., P,
11:17):
> Thanks Robert, so apparently the snapshot version was screwed up somehow
> and included the 2.11 dependencies.
Thanks Robert, so apparently the snapshot version was screwed up somehow
and included the 2.11 dependencies.
Now it works.
Cheers,
Gyula
Gyula Fóra ezt írta (időpont: 2016. febr. 26., P,
11:09):
> That actually seemed to be the issue, not that I compiled my own version
> it doesnt have these w
That actually seemed to be the issue, not that I compiled my own version it
doesnt have these wrond jars in the dependency tree...
Gyula Fóra ezt írta (időpont: 2016. febr. 26., P,
11:01):
> I was using the snapshot repo in this case, let me try building my own
> version...
>
> Maybe this is int
I was using the snapshot repo in this case, let me try building my own
version...
Maybe this is interesting:
mvn dependency:tree | grep 2.11
[INFO] | \- org.apache.kafka:kafka_2.11:jar:0.8.2.2:compile
[INFO] | +- org.scala-lang.modules:scala-xml_2.11:jar:1.0.2:compile
[INFO] | +-
org.scal
Are you building 1.0-SNAPSHOT yourself or are you relying on the snapshot
repository?
We had issues in the past that jars in the snapshot repo were incorrect
On Fri, Feb 26, 2016 at 10:45 AM, Gyula Fóra wrote:
> I am not sure what is happening. I tried running against a Flink cluster
> that is
I am not sure what is happening. I tried running against a Flink cluster
that is definitely running the correct Scala version (2.10) and I still got
the error. So it might be something with the pom.xml but we just don't see
how it is different from the correct one.
Gyula
Till Rohrmann ezt írta (
Hi Gyula,
could it be that you compiled against a different Scala version than the
one you're using for running the job? This usually happens when you compile
against 2.10 and let it run with version 2.11.
Cheers,
Till
On Fri, Feb 26, 2016 at 10:09 AM, Gyula Fóra wrote:
> Hey,
>
> For one of o
Hey,
For one of our jobs we ran into this issue. It's probably some dependency
issue but we cant figure it out as a very similar setup works without
issues for a different program.
java.lang.NoSuchMethodError:
scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object;
at
kafka.consumer.FetchR
15 matches
Mail list logo
